diff --git a/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ConsumerBuilder.java b/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ConsumerBuilder.java index 60e2a93f902bb6..607b32ae1b11f0 100644 --- a/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ConsumerBuilder.java +++ b/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ConsumerBuilder.java @@ -291,6 +291,8 @@ public interface ConsumerBuilder extends Cloneable { *

The listener thread pool is exclusively owned by current consumer * that are using a "listener" model to get messages. For a given internal consumer, * the listener will always be invoked from the same thread, to ensure ordering. + * + *

The user need to shut down the thread pool after closing the consumer to avoid leaks. * @param listenerThreadsProvider the threads provider of the consumer message listener * @return the consumer builder instance */