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 b68d9ce7..39752364 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
@@ -44,14 +44,13 @@ public class KafkaClientRunningTest extends AbstractKafkaTest {
                         //ignore
                     }
                 }
+                connector.unsubscribe();
+                connector.close();
             }
         });
 
         sleep(60000);
         running = false;
-        connector.unsubscribe();
-        connector.close();
-
         executor.shutdown();
         logger.info("shutdown completed");