diff options
| -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 65b2bd6..bff54ab 100644 --- a/kafka/consumer.py +++ b/kafka/consumer.py @@ -123,6 +123,7 @@ class Consumer(object): callback=get_or_init_offset_callback, fail_on_error=False) self.offsets[partition] = offset + self.fetch_offsets = self.offsets.copy() def commit(self, partitions=None): """ |