Fix mock zookeeper change (#1674)

fix mock zookeeper change
streamnative · Mar 6, 2025 · 321209c · 321209c
1 parent 4cdb93b
commit 321209c
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/.../src/test/java/io/streamnative/pulsar/handlers/mqtt/base/MQTTProtocolHandlerTestBase.java b/.../src/test/java/io/streamnative/pulsar/handlers/mqtt/base/MQTTProtocolHandlerTestBase.java
@@ -18,7 +18,6 @@
 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.MQTTCommonConfiguration;
 import io.streamnative.pulsar.handlers.mqtt.utils.ConfigurationUtils;
@@ -419,7 +418,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);