diff --git a/kafka-client/src/test/java/com/alibaba/otter/canal/kafka/client/running/KafkaClientRunningTest.java b/kafka-client/src/test/java/com/alibaba/otter/canal/kafka/client/running/KafkaClientRunningTest.java
index 3260c657..b68d9ce7 100644
--- a/kafka-client/src/test/java/com/alibaba/otter/canal/kafka/client/running/KafkaClientRunningTest.java
+++ b/kafka-client/src/test/java/com/alibaba/otter/canal/kafka/client/running/KafkaClientRunningTest.java
@@ -48,8 +48,10 @@ public class KafkaClientRunningTest extends AbstractKafkaTest {
         });
 
         sleep(60000);
-        connector.disconnect();
         running = false;
+        connector.unsubscribe();
+        connector.close();
+
         executor.shutdown();
         logger.info("shutdown completed");