From f867b183ab2f26a2382a8944076a8067ae3fc48f Mon Sep 17 00:00:00 2001
From: mcy <rewerma@163.com>
Date: Mon, 18 Jun 2018 12:15:28 +0800
Subject: [PATCH] =?UTF-8?q?=E9=99=8D=E4=BD=8Ekafka=E4=BE=9D=E8=B5=96?=
 =?UTF-8?q?=E7=9A=84=E7=89=88=E6=9C=AC=E4=B8=BA0.9.0.1=20=E7=94=B3?=
 =?UTF-8?q?=E6=98=8Eserver=E7=9A=84running=E4=B8=BAvolatile?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 kafka-client/pom.xml                                            | 2 +-
 kafka/pom.xml                                                   | 2 +-
 .../java/com/alibaba/otter/canal/kafka/CanalServerStarter.java  | 2 +-
 3 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/kafka-client/pom.xml b/kafka-client/pom.xml
index 264cfa0c..d814be52 100644
--- a/kafka-client/pom.xml
+++ b/kafka-client/pom.xml
@@ -24,7 +24,7 @@
         <dependency>
             <groupId>org.apache.kafka</groupId>
             <artifactId>kafka-clients</artifactId>
-            <version>0.10.0.1</version>
+            <version>0.9.0.1</version>
         </dependency>
 
         <!-- junit -->
diff --git a/kafka/pom.xml b/kafka/pom.xml
index a4a7b13a..8d3b35d7 100644
--- a/kafka/pom.xml
+++ b/kafka/pom.xml
@@ -29,7 +29,7 @@
         <dependency>
             <groupId>org.apache.kafka</groupId>
             <artifactId>kafka_2.11</artifactId>
-            <version>0.10.0.1</version>
+            <version>0.9.0.1</version>
             <exclusions>
                 <exclusion>
                     <groupId>org.slf4j</groupId>
diff --git a/kafka/src/main/java/com/alibaba/otter/canal/kafka/CanalServerStarter.java b/kafka/src/main/java/com/alibaba/otter/canal/kafka/CanalServerStarter.java
index 24d6a57b..e0b2d1d8 100644
--- a/kafka/src/main/java/com/alibaba/otter/canal/kafka/CanalServerStarter.java
+++ b/kafka/src/main/java/com/alibaba/otter/canal/kafka/CanalServerStarter.java
@@ -19,7 +19,7 @@ public class CanalServerStarter {
 
     private static final String CLASSPATH_URL_PREFIX = "classpath:";
     private static final Logger logger               = LoggerFactory.getLogger(CanalServerStarter.class);
-    private static boolean      running              = false;
+    private volatile static boolean running          = false;
 
     public static void init() {
         try {