微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

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

如何解决是否可以使用新的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应用程序,没问题。

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。