[pulsar-client] fix NPE: while configuring consumer builder (apache#1…

…0063)
instructure · Mar 29, 2021 · 9db880e · 9db880e
1 parent af6eaba
commit 9db880e
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerBuilderImpl.java b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerBuilderImpl.java
@@ -449,7 +449,7 @@ public ConsumerBuilder<T> enableBatchIndexAcknowledgment(boolean batchIndexAckno
     @Override
     public ConsumerBuilder<T> expireTimeOfIncompleteChunkedMessage(long duration, TimeUnit unit) {
         conf.setExpireTimeOfIncompleteChunkedMessageMillis(unit.toMillis(duration));
-        return null;
+        return this;
     }
 
 }