commit on empty batches

forcedotcom · May 20, 2024 · c1a9aa3 · c1a9aa3
1 parent de50f9c
commit c1a9aa3
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/java/src/main/java/genericpubsub/ManagedSubscribe.java b/java/src/main/java/genericpubsub/ManagedSubscribe.java
@@ -97,8 +97,8 @@ private void processEvent(ManagedFetchResponse response) throws IOException {
             logger.info("Processed batch of {} event(s)", response.getEventsList().size());
         }
 
-        // Commit the replay after processing batch of events
-        if (!response.hasCommitResponse() && response.getEventsCount() > 0) {
+        // Commit the replay after processing batch of events or commit the latest replay on an empty batch
+        if (!response.hasCommitResponse()) {
             doCommitReplay(response.getLatestReplayId());
         }
     }