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 {