From b52606a879e0f9dc012d979ca1f3ee3e1c26afbb Mon Sep 17 00:00:00 2001
From: Mateusz Szczygiel <mateusz.szczygiel@allegro.com>
Date: Fri, 4 Oct 2024 13:27:59 +0200
Subject: [PATCH] Clearing maxPendingOffsets map in BatchConsumer

---
 .../pl/allegro/tech/hermes/consumers/consumer/BatchConsumer.java | 1 +
 1 file changed, 1 insertion(+)

diff --git a/hermes-consumers/src/main/java/pl/allegro/tech/hermes/consumers/consumer/BatchConsumer.java b/hermes-consumers/src/main/java/pl/allegro/tech/hermes/consumers/consumer/BatchConsumer.java
index 1da628fa85..03d67d1615 100644
--- a/hermes-consumers/src/main/java/pl/allegro/tech/hermes/consumers/consumer/BatchConsumer.java
+++ b/hermes-consumers/src/main/java/pl/allegro/tech/hermes/consumers/consumer/BatchConsumer.java
@@ -139,6 +139,7 @@ private void commitIfReady() {
             if (!offsetsToCommit.isEmpty()) {
                 commit(offsetsToCommit);
             }
+            maxPendingOffsets.clear();
             lastCommitTime = Instant.now();
         }
     }