Shared subscription: subscription is blocked is nothing is received f…

…rom BookKeeper
datastax · Dec 15, 2021 · 89e19b8 · 89e19b8
1 parent f72c6ac
commit 89e19b8
Showing 1 changed file with 0 additions and 4 deletions.
diff --git a/...va/org/apache/pulsar/broker/service/persistent/PersistentDispatcherMultipleConsumers.java b/...va/org/apache/pulsar/broker/service/persistent/PersistentDispatcherMultipleConsumers.java
@@ -500,10 +500,6 @@ public synchronized void readEntriesComplete(List<Entry> entries, Object ctx) {
     }
 
     protected void sendMessagesToConsumers(ReadType readType, List<Entry> entries) {
-
-        if (entries == null || entries.size() == 0) {
-            return;
-        }
         if (needTrimAckedMessages()) {
             cursor.trimDeletedEntries(entries);
         }