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

问题描述

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

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

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

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

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

解决方法

通常，是的，只要您不使用较新的经纪人提供的功能即可。

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

有一个兼容性列表here，但是自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代理程序运行了Boot应用程序，没问题。