fix NPE

apache · Aug 12, 2024 · 7c3d04e · 7c3d04e
1 parent 202b943
commit 7c3d04e
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/MultiTopicsConsumerImpl.java b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/MultiTopicsConsumerImpl.java
@@ -139,7 +139,9 @@ public class MultiTopicsConsumerImpl<T> extends ConsumerBase<T> {
             long startMessageRollbackDurationInSec) {
         super(client, singleTopic, conf, Math.max(2, conf.getReceiverQueueSize()), executorProvider, subscribeFuture,
                 schema, interceptors);
-        this.internalConsumerInterceptors = getInternalConsumerInterceptors(interceptors);
+        if (interceptors != null) {
+           this.internalConsumerInterceptors = getInternalConsumerInterceptors(interceptors);
+        }
 
         checkArgument(conf.getReceiverQueueSize() > 0,
             "Receiver queue size needs to be greater than 0 for Topics Consumer");