fix mock zookeeper change

coderzc · coderzc · commit 7f2fc75c55b6 · 2025-02-27T12:31:20.000+08:00
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
@@ -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);
 

Original file line number	Diff line number	Diff line change
`@@ -424,7 +424,7 @@ protected void setupBrokerMocks(PulsarService pulsar) throws Exception {`
`424`	`424`	`}`
`425`	`425`
`426`	`426`	`public static MockZooKeeper createMockZooKeeper() throws Exception {`
`427`		`- MockZooKeeper zk = MockZooKeeper.newInstance(MoreExecutors.newDirectExecutorService());`
	`427`	`+ MockZooKeeper zk = MockZooKeeper.newInstance();`
`428`	`428`	`zk.setSessionId(-1);`
`429`	`429`	`List<ACL> dummyAclList = new ArrayList<>(0);`
`430`	`430`