From 321209c116b3af0b8fd5e730619256d3ae5e8fd1 Mon Sep 17 00:00:00 2001 From: Cong Zhao Date: Thu, 27 Feb 2025 14:08:47 +0800 Subject: [PATCH] Fix mock zookeeper change (#1674) fix mock zookeeper change --- .../pulsar/handlers/mqtt/base/MQTTProtocolHandlerTestBase.java | 3 +-- 1 file changed, 1 insertion(+), 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 7b2bc8e5..4fde36d0 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 @@ -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 dummyAclList = new ArrayList<>(0);