[fix][broker] Fix NPE during active consumer is disconnected (#24008)

(cherry picked from commit dbc09e1)
apache · Feb 21, 2025 · 85daa34 · 85daa34
1 parent fb21183
commit 85daa34
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...org/apache/pulsar/broker/service/persistent/PersistentDispatcherSingleActiveConsumer.java b/...org/apache/pulsar/broker/service/persistent/PersistentDispatcherSingleActiveConsumer.java
@@ -350,7 +350,8 @@ void readMoreEntries(Consumer consumer) {
                 final Consumer activeConsumer = getActiveConsumer();
                 if (consumer != activeConsumer) {
                     log.info("[{}] cancel the readMoreEntries because consumer {} is no longer the active consumer {}",
-                            topic.getName(), consumer.consumerName(), activeConsumer.consumerName());
+                            topic.getName(), consumer.consumerName(),
+                            activeConsumer != null ? activeConsumer.consumerName() : null);
                     return;
                 }
                 if (havePendingRead) {