diff options
Diffstat (limited to 'kafka/consumer.py')
| -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 |