lhotari commented on code in PR #22861:
URL: https://github.com/apache/pulsar/pull/22861#discussion_r1630090531
##########
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ConsumerBuilder.java:
##########
@@ -283,6 +283,21 @@ public interface ConsumerBuilder<T> extends Cloneable {
*/
ConsumerBuilder<T> messageListener(MessageListener<T> messageListener);
+ /**
+ * Set the {@link ThreadPoolProvider} to be used for message listeners of
<b>current consumer</b>.
+ * <i>(default: use executor from PulsarClient,
+ * {@link
org.apache.pulsar.client.impl.PulsarClientImpl#externalExecutorProvider})</i>.
+ *
+ * <p>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.
+ *
+ * <p> 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
+ */
+ ConsumerBuilder<T> listenerThreadsProvider(ThreadPoolProvider
listenerThreadsProvider);
Review Comment:
I believe that this would be sufficient for the use case:
```suggestion
ConsumerBuilder<T> messageListenerExecutor(java.util.concurrent.Executor
executor);
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscr...@pulsar.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
