From 25bcdc0d49ed13497fb8d6c4bb3bf0a1a55a3bd7 Mon Sep 17 00:00:00 2001
From: Dana Powers <dana.powers@gmail.com>
Date: Sun, 16 Mar 2025 19:14:22 -0700
Subject: [PATCH] Fix consumer offset tracking on pause/resume

---
 kafka/consumer/subscription_state.py | 1 +
 1 file changed, 1 insertion(+)

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