also reset self.fetch_offsets in fetch_last_known_offsets

zackdever · zackdever · commit 02007b0e80ed · 2014-08-25T12:00:19.000-07:00
diff --git a/kafka/consumer.py b/kafka/consumer.py
@@ -123,6 +123,7 @@ def get_or_init_offset_callback(resp):
                           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):
         """
