Fix ClassCastException when scheduling to look up (#1280)

streamnative · Mar 14, 2024 · 5e4237c · 5e4237c
1 parent 88d81d7
commit 5e4237c
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/.../src/main/java/io/streamnative/pulsar/handlers/mqtt/proxy/PulsarServiceLookupHandler.java b/.../src/main/java/io/streamnative/pulsar/handlers/mqtt/proxy/PulsarServiceLookupHandler.java
@@ -37,6 +37,7 @@
 import org.apache.pulsar.client.impl.PulsarClientImpl;
 import org.apache.pulsar.client.impl.conf.ClientConfigurationData;
 import org.apache.pulsar.client.util.ExecutorProvider;
+import org.apache.pulsar.client.util.ScheduledExecutorProvider;
 import org.apache.pulsar.common.naming.TopicName;
 import org.apache.pulsar.common.util.FutureUtil;
 import org.apache.pulsar.metadata.api.MetadataCache;
@@ -58,7 +59,8 @@ public class PulsarServiceLookupHandler implements LookupHandler {
     public PulsarServiceLookupHandler(PulsarService pulsarService, MQTTProxyConfiguration proxyConfig) {
         this.pulsarService = pulsarService;
         this.proxyConfig = proxyConfig;
-        this.executorProvider = new ExecutorProvider(proxyConfig.getLookupThreadPoolNum(), "mop-lookup-thread");
+        this.executorProvider = new ScheduledExecutorProvider(proxyConfig.getLookupThreadPoolNum(),
+                                                              "mop-lookup-thread");
         this.localBrokerDataCache = pulsarService
                 .getLocalMetadataStore().getMetadataCache(LocalBrokerData.class);
         this.pulsarClient = getClient(proxyConfig);