在远程 kafka 云集群中,kafka 代理将更新到新版本 (5.1),因此应用新的 kafka 协议。
现在我应该更新我的 kafka 客户端以便能够连接。现在我在我的 spring-boot 应用程序中使用以下 kafka 相关依赖项:
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-parent</artifactId>
<version>1.3.8.RELEASE</version>
<groupId>org.springframework.integration</groupId>
<artifactId>spring-integration-kafka</artifactId>
<version>2.0.1.RELEASE</version>
<groupId>org.springframework.kafka</groupId>
<artifactId>spring-kafka-test</artifactId>
<version>1.0.3.RELEASE</version>
<groupId>org.springframework.kafka</groupId>
<artifactId>spring-kafka</artifactId>
<version>1.0.3.RELEASE</version>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka-clients</artifactId>
<version>0.9.0.1</version>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka_2.11</artifactId>
<version>0.9.0.1</version>
我已经为 kafka 客户端和 kafka 经纪人寻找合适的兼容性矩阵。
- 有人知道如何成功升级吗?
- 有人有这个依赖关系的兼容性矩阵吗?
From https://github.com/spring-cloud/spring-cloud-stream/wiki/Kafka-Client-Compatibility
兼容性矩阵
+--------+--------------+------------------+---------------+-------------+
| Spring | Spring for | Spring | kafka-clients | Kafka |
| Cloud | Apache Kafka | Integration | | Broker |
| Stream | | for Apache Kafka | | |
+--------+--------------+------------------+---------------+-------------+
| 2.1.x | 2.2.x | 3.1.x | 2.0.0, | 2.0.0, |
| | | | 1.1.x, | 1.1.x, |
| | | | 1.0.x(*) | 1.0.x, |
| | | | | 0.11.0.x(*) |
+--------+--------------+------------------+---------------+-------------+
| 2.0.x | 2.1.x | 3.0.x | 1.1.x, | 1.1.x, |
| | | | 1.0.x(*) | 1.0.x, |
| | | | | 0.11.0.x(*) |
+--------+--------------+------------------+---------------+-------------+
| 1.3.x | 1.3.x, | 2.3.x, | 0.11.0.x(**), | 0.10.x.x |
| | 1.2.x, | 2.2.x, | 0.10.2.x | or higher |
| | 1.1.x | 2.1.x | | |
+--------+--------------+------------------+---------------+-------------+
| 1.2.x | 1.2.x, | 2.2.x, | 0.10.1.x | 0.10.x.x |
| | 1.1.x | 2.1.x | | or higher |
+--------+--------------+------------------+---------------+-------------+
其他来源
- https://cwiki.apache.org/confluence/display/KAFKA/Compatibility+Matrix
- https://spring.io/projects/spring-kafka
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)