[fix][build] Call sendMessagesToConsumers

Signed-off-by: Zixuan Liu <nodeces@gmail.com>
ascentstream · Sep 10, 2024 · 3e37978 · 3e37978
1 parent 6176720
commit 3e37978
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...ache/pulsar/broker/service/persistent/PersistentStreamingDispatcherMultipleConsumers.java b/...ache/pulsar/broker/service/persistent/PersistentStreamingDispatcherMultipleConsumers.java
@@ -95,7 +95,7 @@ public synchronized void readEntryComplete(Entry entry, PendingReadEntryRequest
         long size = entry.getLength();
         updatePendingBytesToDispatch(size);
 
-        if (sendMessagesToConsumers(readType, Lists.newArrayList(entry), ctx.isLast())) {
+        if (sendMessagesToConsumers(readType, Lists.newArrayList(entry))) {
             readMoreEntriesAsync();
         } else {
             updatePendingBytesToDispatch(-size);