diff --git a/connector/kafka-connector/pom.xml b/connector/kafka-connector/pom.xml
index 20f243bb..a1c4d882 100644
--- a/connector/kafka-connector/pom.xml
+++ b/connector/kafka-connector/pom.xml
@@ -28,7 +28,7 @@
         </dependency>
         <dependency>
             <groupId>org.apache.kafka</groupId>
-            <artifactId>kafka_2.11</artifactId>
+            <artifactId>kafka-clients</artifactId>
             <version>${kafka_version}</version>
         </dependency>
         <dependency>
diff --git a/example/pom.xml b/example/pom.xml
index aca63ed9..aa1b9c04 100644
--- a/example/pom.xml
+++ b/example/pom.xml
@@ -21,6 +21,43 @@
 			<artifactId>canal.protocol</artifactId>
 			<version>${project.version}</version>
 		</dependency>
+		<!-- 客户端要使用请单独引入mq-clients依赖 -->
+		<dependency>
+			<groupId>org.apache.rocketmq</groupId>
+			<artifactId>rocketmq-client</artifactId>
+			<version>${rocketmq_version}</version>
+		</dependency>
+		<dependency>
+			<groupId>org.apache.rocketmq</groupId>
+			<artifactId>rocketmq-acl</artifactId>
+			<version>${rocketmq_version}</version>
+		</dependency>
+		<dependency>
+			<groupId>com.rabbitmq</groupId>
+			<artifactId>amqp-client</artifactId>
+			<version>${rabbitmq_version}</version>
+		</dependency>
+		<dependency>
+			<groupId>com.alibaba.mq-amqp</groupId>
+			<artifactId>mq-amqp-client</artifactId>
+			<version>${mq_amqp_client}</version>
+		</dependency>
+		<dependency>
+			<groupId>org.apache.kafka</groupId>
+			<artifactId>kafka-clients</artifactId>
+			<version>${kafka_version}</version>
+		</dependency>
+		<!-- Pulsar -->
+		<dependency>
+			<groupId>org.apache.pulsar</groupId>
+			<artifactId>pulsar-client</artifactId>
+			<version>${pulsar_version}</version>
+		</dependency>
+		<dependency>
+			<groupId>org.apache.pulsar</groupId>
+			<artifactId>pulsar-client-admin</artifactId>
+			<version>${pulsar_version}</version>
+		</dependency>
 		<!-- test dependency -->
 		<dependency>
 			<groupId>junit</groupId>
diff --git a/pom.xml b/pom.xml
index 37f3c22c..48b58f34 100644
--- a/pom.xml
+++ b/pom.xml
@@ -104,7 +104,7 @@
         <rocketmq_version>4.8.0</rocketmq_version>
         <rabbitmq_version>5.5.0</rabbitmq_version>
         <mq_amqp_client>1.0.3</mq_amqp_client>
-        <kafka_version>1.1.1</kafka_version>
+        <kafka_version>2.4.0</kafka_version>
         <pulsar_version>2.8.1</pulsar_version>
         <mysql_driver_version>5.1.48</mysql_driver_version>
         <maven-jacoco-plugin.version>0.8.3</maven-jacoco-plugin.version>