我有以下配置:
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有很大不同。
我的问题是:我能否面对一些兼容的问题?
我有以下配置:
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有很大不同。
我的问题是:我能否面对一些兼容的问题?
1条答案
按热度按时间pw9qyyiw1#
我在用兔子。
你应该没事的;它可能与源代码中较新的Kafkajar一起工作
/lib
因为每个模块都加载在自己的类加载器中,所以不应该与xd/lib
罐。但是,您可能需要从中移除旧的Kafkajar
xd/lib
目录(这就是我询问消息总线的原因)。