From ce9ceaad307d74a3861b1060e2ce250dc2dd63be Mon Sep 17 00:00:00 2001
From: coderzc <zhaocong@apache.org>
Date: Thu, 27 Feb 2025 12:31:20 +0800
Subject: [PATCH] fix mock zookeeper change

---
 .../handlers/mqtt/base/MQTTProtocolHandlerTestBase.java       | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/tests/src/test/java/io/streamnative/pulsar/handlers/mqtt/base/MQTTProtocolHandlerTestBase.java b/tests/src/test/java/io/streamnative/pulsar/handlers/mqtt/base/MQTTProtocolHandlerTestBase.java
index 80fd1f21..8d7bcdd6 100644
--- a/tests/src/test/java/io/streamnative/pulsar/handlers/mqtt/base/MQTTProtocolHandlerTestBase.java
+++ b/tests/src/test/java/io/streamnative/pulsar/handlers/mqtt/base/MQTTProtocolHandlerTestBase.java
@@ -16,9 +16,9 @@
 import static org.mockito.ArgumentMatchers.any;
 import static org.mockito.Mockito.doReturn;
 import static org.mockito.Mockito.spy;
+
 import com.google.common.base.Joiner;
 import com.google.common.collect.Sets;
-import com.google.common.util.concurrent.MoreExecutors;
 import io.netty.channel.EventLoopGroup;
 import io.streamnative.pulsar.handlers.mqtt.common.MQTTCommonConfiguration;
 import io.streamnative.pulsar.handlers.mqtt.common.utils.ConfigurationUtils;
@@ -424,7 +424,7 @@ protected void setupBrokerMocks(PulsarService pulsar) throws Exception {
     }
 
     public static MockZooKeeper createMockZooKeeper() throws Exception {
-        MockZooKeeper zk = MockZooKeeper.newInstance(MoreExecutors.newDirectExecutorService());
+        MockZooKeeper zk = MockZooKeeper.newInstance();
         zk.setSessionId(-1);
         List<ACL> dummyAclList = new ArrayList<>(0);