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

apache · Feb 20, 2025 · dbc09e1 · dbc09e1
1 parent 28f7845
commit dbc09e1
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) {