diff --git a/kafka-client/src/test/java/com/alibaba/otter/canal/kafka/client/running/CanalKafkaClientExample.java b/kafka-client/src/test/java/com/alibaba/otter/canal/kafka/client/running/CanalKafkaClientExample.java
index a7c6b78c..f7c22cd4 100644
--- a/kafka-client/src/test/java/com/alibaba/otter/canal/kafka/client/running/CanalKafkaClientExample.java
+++ b/kafka-client/src/test/java/com/alibaba/otter/canal/kafka/client/running/CanalKafkaClientExample.java
@@ -91,6 +91,7 @@ public class CanalKafkaClientExample {
     }
 
     private void process() {
+        while (!running) ;
         try {
             connector.subscribe();
             while (running) {