Skip to content

Commit 3ffa2e8

Browse files
agapplezoemak
authored andcommitted
upgrade kafka-client 2.4.0
1 parent e481de5 commit 3ffa2e8

File tree

3 files changed

+39
-2
lines changed

3 files changed

+39
-2
lines changed

connector/kafka-connector/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,7 @@
2828
</dependency>
2929
<dependency>
3030
<groupId>org.apache.kafka</groupId>
31-
<artifactId>kafka_2.11</artifactId>
31+
<artifactId>kafka-clients</artifactId>
3232
<version>${kafka_version}</version>
3333
</dependency>
3434
<dependency>

example/pom.xml

Lines changed: 37 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -21,6 +21,43 @@
2121
<artifactId>canal.protocol</artifactId>
2222
<version>${project.version}</version>
2323
</dependency>
24+
<!-- 客户端要使用请单独引入mq-clients依赖 -->
25+
<dependency>
26+
<groupId>org.apache.rocketmq</groupId>
27+
<artifactId>rocketmq-client</artifactId>
28+
<version>${rocketmq_version}</version>
29+
</dependency>
30+
<dependency>
31+
<groupId>org.apache.rocketmq</groupId>
32+
<artifactId>rocketmq-acl</artifactId>
33+
<version>${rocketmq_version}</version>
34+
</dependency>
35+
<dependency>
36+
<groupId>com.rabbitmq</groupId>
37+
<artifactId>amqp-client</artifactId>
38+
<version>${rabbitmq_version}</version>
39+
</dependency>
40+
<dependency>
41+
<groupId>com.alibaba.mq-amqp</groupId>
42+
<artifactId>mq-amqp-client</artifactId>
43+
<version>${mq_amqp_client}</version>
44+
</dependency>
45+
<dependency>
46+
<groupId>org.apache.kafka</groupId>
47+
<artifactId>kafka-clients</artifactId>
48+
<version>${kafka_version}</version>
49+
</dependency>
50+
<!-- Pulsar -->
51+
<dependency>
52+
<groupId>org.apache.pulsar</groupId>
53+
<artifactId>pulsar-client</artifactId>
54+
<version>${pulsar_version}</version>
55+
</dependency>
56+
<dependency>
57+
<groupId>org.apache.pulsar</groupId>
58+
<artifactId>pulsar-client-admin</artifactId>
59+
<version>${pulsar_version}</version>
60+
</dependency>
2461
<!-- test dependency -->
2562
<dependency>
2663
<groupId>junit</groupId>

pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -104,7 +104,7 @@
104104
<rocketmq_version>4.8.0</rocketmq_version>
105105
<rabbitmq_version>5.5.0</rabbitmq_version>
106106
<mq_amqp_client>1.0.3</mq_amqp_client>
107-
<kafka_version>1.1.1</kafka_version>
107+
<kafka_version>2.4.0</kafka_version>
108108
<pulsar_version>2.8.1</pulsar_version>
109109
<mysql_driver_version>5.1.48</mysql_driver_version>
110110
<maven-jacoco-plugin.version>0.8.3</maven-jacoco-plugin.version>

0 commit comments

Comments
 (0)