Clearing maxPendingOffsets map in BatchConsumer

allegro · Oct 4, 2024 · b52606a · b52606a
1 parent 37656e2
commit b52606a
Showing 1 changed file with 1 addition and 0 deletions.
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
@@ -139,6 +139,7 @@ private void commitIfReady() {
             if (!offsetsToCommit.isEmpty()) {
                 commit(offsetsToCommit);
             }
+            maxPendingOffsets.clear();
             lastCommitTime = Instant.now();
         }
     }