You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
When trying to seek with whence equal to 1 we get an exception
---->1consumer.seek(1, 1)
/usr/local/lib/python2.7/dist-packages/kafka/consumer.pycinseek(self, offset, whence)
79ifwhence==1: # relative to current position80forpartition, _offsetinself.offsets.items():
--->81self.offset[partition] =_offset+offset82elifwhencein (0, 2): # relative to beginning or end83# divide the request offset by number of partitions, distribute the remained evenlyAttributeError: 'SimpleConsumer'objecthasnoattribute'offset'
It looks like self.offset should be self.offsets
The text was updated successfully, but these errors were encountered:
When trying to seek with
whence
equal to1
we get an exceptionIt looks like
self.offset
should beself.offsets
The text was updated successfully, but these errors were encountered: