Spring-Kafka 1.3.9 与 Kafka 客户端 0.10.2.2 不兼容

Question

我在使用 Kafka 客户端 0.10.2.2 运行 Spring-Kafka 版本 1.3.9 时遇到问题

https://spring.io/projects/spring-kafka 说“建议所有具有代理 >= 0.10.xx 的用户（以及所有 spring boot 1.5.x 用户）使用 spring-kafka 1.3.x 或更高版本”我在我的 pom.xml 中设置了。 xml Spring-Kafka 版本 1.3.9 并将 Kafka 客户端从 0.11.xx 覆盖到 0.10.2.2

当我运行实例时出现此错误：

引起：java.lang.NoClassDefFoundError： org/apache/kafka/common/header/Headers 在 org.springframework.kafka.core.KafkaTemplate.(KafkaTemplate.java:74) ~[spring-kafka-1.3.9.RELEASE.jar:?]

0.11.x.x 包含包头。但是，版本 0.10.2.2 没有。 0.10.x.x 版本的代理与 spring-kafka 1.3.9 版本不兼容。这与 spring-kafka 网站所说的相反。如果我错了，请纠正我。

我的问题是使用 0.11.xx 版本而不是 0.10.xx 版本有什么问题吗？我看不到两个版本之间的发行说明。顺便说一句，我的 Kafka 实例在 0.10.x.x 版本上运行。谢谢

Answer 1

请不要在多个地方问同一个问题；这是在浪费我们（和您）的时间。

正如我在 GitHub 问题中所说...

您不应降级kafka-clients。 0.11 客户端可以与 0.10.x.x 代理通信。

见the Confluent compatibility matrix。

我觉得项目页面的表格比较清楚；它声明 spring-kafka 1.3.x 与 0.11.x.x 和 1.0.x.x 客户端兼容。

有关客户端/代理兼容性的完整讨论，请参阅Kafka Compatibility Matrix。

如果我们可以更清楚地告诉我。

请注意，虽然 0.11 客户端可以与 0.10 代理一起使用，但您显然不能使用 0.11 代理功能（例如标头）。

0.10.x.x 已经很老了。当前版本是 2.2.1（2.3.0 即将推出）。这些年来有很多改进。