From 2435f6a275fbe2d6f909fa1400f591151cc66c0f Mon Sep 17 00:00:00 2001
From: Masahiro Sakamoto <massakam@yahoo-corp.jp>
Date: Mon, 15 Feb 2021 16:35:46 +0900
Subject: [PATCH] Fix NPE that occurs in
 PersistentStickyKeyDispatcherMultipleConsumers when debug log is enabled

---
 .../PersistentStickyKeyDispatcherMultipleConsumers.java         | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentStickyKeyDispatcherMultipleConsumers.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentStickyKeyDispatcherMultipleConsumers.java
index 08ea07ff2d46d..3107f13c2865c 100644
--- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentStickyKeyDispatcherMultipleConsumers.java
+++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentStickyKeyDispatcherMultipleConsumers.java
@@ -181,7 +181,7 @@ protected void sendMessagesToConsumers(ReadType readType, List<Entry> entries) {
                     maxMessagesForC, readType);
             if (log.isDebugEnabled()) {
                 log.debug("[{}] select consumer {} with messages num {}, read type is {}",
-                        name, consumer.consumerName(), messagesForC, readType);
+                        name, consumer == null ? "null" : consumer.consumerName(), messagesForC, readType);
             }
 
             if (messagesForC < entriesWithSameKeyCount) {