From cc5eb1075ba82eeef4fb4e88b8a8235c062ab272 Mon Sep 17 00:00:00 2001
From: rewerma <rewerma@163.com>
Date: Wed, 13 Jun 2018 15:51:28 +0800
Subject: [PATCH] =?UTF-8?q?kafka=20consumer=20example=20=E4=BF=AE=E6=94=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../canal/kafka/client/running/CanalKafkaClientExample.java      | 1 +
 1 file changed, 1 insertion(+)

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) {