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(); } }