From 19f4c5ae1bd88522048cf32dcb598c48ab2e0b58 Mon Sep 17 00:00:00 2001
From: rewerma <rewerma@163.com>
Date: Wed, 13 Jun 2018 15:40:49 +0800
Subject: [PATCH] =?UTF-8?q?kafka=20consumer=20=E6=B5=8B=E8=AF=95=E7=B1=BB?=
 =?UTF-8?q?=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/KafkaClientRunningTest.java    | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)

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 39752364..9d462554 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
@@ -28,11 +28,11 @@ public class KafkaClientRunningTest extends AbstractKafkaTest {
         final ExecutorService executor = Executors.newFixedThreadPool(1);
 
         final KafkaCanalConnector connector = KafkaCanalConnectors.newKafkaConnector(servers, topic, partition, groupId);
-        connector.subscribe();
 
         executor.submit(new Runnable() {
             @Override
             public void run() {
+                connector.subscribe();
                 while (running) {
                     try {
                         Message message = connector.getWithoutAck(3L, TimeUnit.SECONDS);
@@ -53,8 +53,6 @@ public class KafkaClientRunningTest extends AbstractKafkaTest {
         running = false;
         executor.shutdown();
         logger.info("shutdown completed");
-
-        sleep(10000);
     }
 
 }