diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentDispatcherSingleActiveConsumer.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentDispatcherSingleActiveConsumer.java index b451a8ad5dc0d..7032a057e9046 100644 --- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentDispatcherSingleActiveConsumer.java +++ b/pulsar-broker/src/main/java/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) {