springxd/spring集成:为生产者和消费者使用不同版本的spring集成kafka

azpvetkf  于 2021-06-07  发布在  Kafka
关注(0)|答案(1)|浏览(361)

我有以下配置:
spring集成kafka 1.3.1.release
我有一个自定义KafkaFlume和自定义Kafka源
我想要的配置:
我想继续使用spring集成kafka 1.3.1.release和我的定制kafkaFlume。
我将kafka源代码逻辑更改为使用spring-integration-kafka-2.1.0.release。我注意到实现消费者/生产者的方式与以前版本的spring集成kafka有很大不同。
我的问题是:我能否面对一些兼容的问题?

pw9qyyiw

pw9qyyiw1#

我在用兔子。
你应该没事的;它可能与源代码中较新的Kafkajar一起工作 /lib 因为每个模块都加载在自己的类加载器中,所以不应该与 xd/lib 罐。
但是,您可能需要从中移除旧的Kafkajar xd/lib 目录(这就是我询问消息总线的原因)。

相关问题