spring-kafka - 是否可以使用新版本的 spring-kafka（如 v2.5.4.RELEASE）连接到旧的 Kafka 版本（如 0.11）？

Question

我构建了一个 Spring Boot 应用程序来在 Kafka 中生成数据，但现在我需要将此应用程序连接到旧的 Kafka (0.11v)。我尝试只更改引导服务器，但收到连接错误。

我仔细检查了这个 Kafka 实例是否正常工作，以及其他应用程序是否正在连接。

我的问题是，像 v2.5.4.RELEASE 这样的新版本 spring-Kafka 是否可以连接到旧版本的 Kafka。我可以添加任何配置来使用旧版 Kafka 实例吗？我构建了一个 Spring Boot 应用程序来在 Kafka 中生成数据，但现在我需要将此应用程序连接到旧的 Kafka (0.11v)。我尝试只更改引导服务器，但收到连接错误。

我仔细检查了这个 Kafka 实例是否正常工作，以及其他应用程序是否正在连接。

我的问题是，像 v2.5.4.RELEASE 这样的新版本 spring-Kafka 是否可以连接到旧版本的 Kafka。我可以添加任何配置来使用旧版 Kafka 实例吗？

Answer 1

一般来说，是的，只要您不使用较新的经纪人提供的功能。

自 0.10.2.x 以来，Java 客户端的向后兼容性一直很好。

此处有一个兼容性矩阵，但自 1.0.0 客户端以来尚未更新。

SK v2.5.4 使用 2.5.0 客户端（2.5.5 使用 2.5.1）。我最近没有尝试连接到这么老的经纪人，连接错误的性质是什么？

编辑

我刚刚使用 Spring Kafka 2.5.5 针对 0.11.0.3 代理运行了一个启动应用程序，没有任何问题。