diff options
| author | Mark Roberts <markroberts@kixeye.com> | 2014-03-25 11:07:31 -0700 |
|---|---|---|
| committer | Mark Roberts <markroberts@kixeye.com> | 2014-03-25 11:07:31 -0700 |
| commit | e5af3170f3f7fb095526269ff20e897ab08c0015 (patch) | |
| tree | 94b226373c977afd86223717330c16208aa1d7ad | |
| parent | 9bed11db98387c0d9e456528130b330631dc50af (diff) | |
| download | kafka-python-e5af3170f3f7fb095526269ff20e897ab08c0015.tar.gz | |
Make seek(); commit(); work without commit discarding the seek change
| -rw-r--r-- | kafka/consumer.py | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/kafka/consumer.py b/kafka/consumer.py index 28b53ec..1404097 100644 --- a/kafka/consumer.py +++ b/kafka/consumer.py @@ -275,6 +275,7 @@ class SimpleConsumer(Consumer): 2 is relative to the latest known offset (tail) """ + self.count_since_commit += 1 if whence == 1: # relative to current position for partition, _offset in self.offsets.items(): self.offsets[partition] = _offset + offset |