diff options
| author | Ivan Pouzyrevsky <sandello@yandex-team.ru> | 2013-06-02 01:26:14 +0400 |
|---|---|---|
| committer | David Arthur <mumrah@gmail.com> | 2013-06-07 21:20:55 -0400 |
| commit | e073b3310d0b29ac4c7cfd0c9b73ffa346f5ba74 (patch) | |
| tree | bde4e20aaddfe743467511996fa81cae425bb691 /kafka/consumer.py | |
| parent | 6704050e50a2934806e349ac875f2ab31ccfcd9d (diff) | |
| download | kafka-python-e073b3310d0b29ac4c7cfd0c9b73ffa346f5ba74.tar.gz | |
Refactor and update integration tests
Diffstat (limited to 'kafka/consumer.py')
| -rw-r--r-- | kafka/consumer.py | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/kafka/consumer.py b/kafka/consumer.py index 3b64571..c9f12e1 100644 --- a/kafka/consumer.py +++ b/kafka/consumer.py @@ -83,6 +83,11 @@ class SimpleConsumer(object): for partition in self.client.topic_partitions[topic]: self.offsets[partition] = 0 + def stop(self): + if self.commit_timer is not None: + self.commit_timer.stop() + self.commit() + def seek(self, offset, whence): """ Alter the current offset in the consumer, similar to fseek |