Skip to content

Commit e5af317

Browse files
author
Mark Roberts
committed
Make seek(); commit(); work without commit discarding the seek change
1 parent 9bed11d commit e5af317

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

kafka/consumer.py

+1
Original file line numberDiff line numberDiff line change
@@ -275,6 +275,7 @@ def seek(self, offset, whence):
275275
2 is relative to the latest known offset (tail)
276276
"""
277277

278+
self.count_since_commit += 1
278279
if whence == 1: # relative to current position
279280
for partition, _offset in self.offsets.items():
280281
self.offsets[partition] = _offset + offset

0 commit comments

Comments
 (0)