From e52bd097d268c0ecb2d3fc5a89fd4578d325358c Mon Sep 17 00:00:00 2001 From: Zixuan Liu Date: Mon, 14 Oct 2024 21:35:22 +0800 Subject: [PATCH] use the single thread as lookupExecutorProvider Signed-off-by: Zixuan Liu --- .../java/org/apache/pulsar/client/impl/PulsarClientImpl.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/PulsarClientImpl.java b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/PulsarClientImpl.java index 6448a3651aa93..603844eeb786e 100644 --- a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/PulsarClientImpl.java +++ b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/PulsarClientImpl.java @@ -232,7 +232,7 @@ private PulsarClientImpl(ClientConfigurationData conf, EventLoopGroup eventLoopG this.internalExecutorProvider = internalExecutorProvider != null ? internalExecutorProvider : new ExecutorProvider(conf.getNumIoThreads(), "pulsar-client-internal"); this.lookupExecutorProvider = lookupExecutorProvider != null ? lookupExecutorProvider : - new ExecutorProvider(conf.getNumIoThreads(), "pulsar-client-lookup"); + new ExecutorProvider(1, "pulsar-client-lookup"); if (conf.getServiceUrl().startsWith("http")) { lookup = new HttpLookupService(instrumentProvider, conf, this.eventLoopGroup); } else {