降低kafka依赖的版本为0.9.0.1

申明server的running为volatile

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

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>

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 {