We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent bff6cae commit eff8d2bCopy full SHA for eff8d2b
kafka/consumer.py
@@ -78,7 +78,7 @@ def seek(self, offset, whence):
78
"""
79
if whence == 1: # relative to current position
80
for partition, _offset in self.offsets.items():
81
- self.offset[partition] = _offset + offset
+ self.offsets[partition] = _offset + offset
82
elif whence in (0, 2): # relative to beginning or end
83
# divide the request offset by number of partitions, distribute the remained evenly
84
(delta, rem) = divmod(offset, len(self.offsets))
0 commit comments