diff --git a/kafka/consumer/subscription_state.py b/kafka/consumer/subscription_state.py index 0cfcfd2d4..0083c2dbc 100644 --- a/kafka/consumer/subscription_state.py +++ b/kafka/consumer/subscription_state.py @@ -413,6 +413,7 @@ def seek(self, offset): def pause(self): self.paused = True + self.last_offset_from_record_batch = None def resume(self): self.paused = False