diff --git a/kafka-client/pom.xml b/kafka-client/pom.xml
index 5444af5d..42424ddd 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.9.0.1</version>
+            <version>1.1.1</version>
         </dependency>
 
         <!-- junit -->
diff --git a/kafka/pom.xml b/kafka/pom.xml
index d46a2d03..b2587c02 100644
--- a/kafka/pom.xml
+++ b/kafka/pom.xml
@@ -25,11 +25,10 @@
             <artifactId>snakeyaml</artifactId>
             <version>1.17</version>
         </dependency>
-
         <dependency>
             <groupId>org.apache.kafka</groupId>
             <artifactId>kafka_2.11</artifactId>
-            <version>0.9.0.1</version>
+            <version>1.1.1</version>
             <exclusions>
                 <exclusion>
                     <groupId>org.slf4j</groupId>
@@ -37,6 +36,12 @@
                 </exclusion>
             </exclusions>
         </dependency>
+        <!--kafka_2.11_1.1.1 exclusion掉了netty 的依赖，但CanalServerWithNetty 依赖 netty3,升级kafka至 1.1.1 需要显示加入,否则会启动失败 -->
+        <dependency>
+            <groupId>org.jboss.netty</groupId>
+            <artifactId>netty</artifactId>
+            <version>3.2.2.Final</version>
+        </dependency>
     </dependencies>
 
     <build>