确定Kafka-Client与kafka-broker的兼容性
在遥远的kafka云团中，kafka代理将更新到新版本(5.1)，因此适用新的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>
-
null
共有1个答案
摘自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/兼容性+矩阵
- https://spring.io/projects/spring-kafka
-
我们有一个“Kerberized Kafka集群”，运行Apache Kafka 0.11版的代理。这个集群由另一个团队管理，我们对此没有任何控制权。 我们现在正在尝试在我们自己的K8S集群上安装Kafka Connect集群。 我们遵循这个兼容性矩阵https://docs.confluent.io/current/installation/versions-interoperability.h
-
这个链接说：Apache Kafka 0.9.0.1 http://docs.spring.io/spring-kafka/docs/1.1.3.build-snapshot/reference/html/_integrate.html
-
https://spring.io/projects/spring-kafka指出，“所有brokers>=0.10.x.x的用户（以及所有spring boot 1.5.x用户）建议使用spring-kafka 1.3.x或更高版本”我已经在pom.xml中设置了spring-kafka 1.3.9版本，并将Kafka客户端从0.11.x.x覆盖到0.10.2.2 当我运行实例时，我会出现以下错
-
我需要从Kafka主题获取消息并通过基于HTTP的API通知其他系统。也就是说，从主题获取消息，映射到第三方API并调用它们。我打算为此编写一个Kafka Sink连接器。 对于这个用例，Kafka Connect是正确的选择还是我应该使用Kafka客户端。
-
原文档 组件源码 组件示例 中英文对照表 consumer：消费者 consumer group：消费组（Kafka中的设计） partition：分区（Kafka中的设计） producer: 生产者 offset：偏移量 组件介绍 此组件提供了 Kafka Client 的集成，可以以 Vert.x 的方式从 Apache Kafka 集群上消费或者发送消息。 对于消费者(consumer)，
-
我正在使用从oracle db获取数据，并按下（两个键 我有一个Kafka流收听这个主题，并有avro Genericrecord。当我启动流时，我开始得到＜code＞ClassCastException:java.lang.Long不能强制转换为org.apache.avro.generic。GenericRecordconnect生成的架构具有数据类型为“long”的字段 有人对如何解决这个问