[pulsar-client] fix NPE: while configuring consumer builder
@@ -449,7 +449,7 @@ public class ConsumerBuilderImpl<T> implements ConsumerBuilder<T> {
@Override
public ConsumerBuilder<T> expireTimeOfIncompleteChunkedMessage(long duration, TimeUnit unit) {
conf.setExpireTimeOfIncompleteChunkedMessageMillis(unit.toMillis(duration));
- return null;
+ return this;
}
}
