From 4e41ebf746822ed098e9d6b43a08b807a9d84df1 Mon Sep 17 00:00:00 2001
From: rewerma <rewerma@163.com>
Date: Wed, 13 Jun 2018 15:38:24 +0800
Subject: [PATCH] =?UTF-8?q?kafka=20consumer=20close=E6=96=B9=E5=BC=8F?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../canal/kafka/client/running/KafkaClientRunningTest.java   | 5 ++---
 1 file changed, 2 insertions(+), 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 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");