From 679fd464f4b18a25b3a152785da480ec03f93d56 Mon Sep 17 00:00:00 2001
From: winger <winger2049@gmail.com>
Date: Tue, 14 Aug 2018 16:09:44 +0800
Subject: [PATCH] =?UTF-8?q?=E5=8D=87=E7=BA=A7Kafka=20=E7=89=88=E6=9C=AC?=
 =?UTF-8?q?=E8=87=B3=202.11=5F1.1.1?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 kafka-client/pom.xml | 2 +-
 kafka/pom.xml        | 9 +++++++--
 2 files changed, 8 insertions(+), 3 deletions(-)

diff --git a/kafka-client/pom.xml b/kafka-client/pom.xml
index d814be52..b589bd16 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 8d3b35d7..f1f099ed 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>