如何解决是否可以使用新的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 举报,一经查实,本站将立刻删除。