2017-04-04 68 views
1

我有以下配置:SpringXD/Spring集成:使用不同版本的弹簧集成 - 卡夫卡对生产者和消费者

  • Spring的集成 - 卡夫卡1.3.1.RELEASE
  • 我有一个自定义卡夫卡水槽和一个自定义的卡夫卡源

的配置我想有:

  • 我想仍然使用Spring-integration-kafka 1.3.1.RELEASE和我自定义的kafka-sink。
  • 我改变了我的卡夫卡型逻辑使用Spring的集成 - 卡夫卡2.1.0.RELEASE。我注意到实现消费者/生产者的方式与先前版本的Spring-integration-kafka有所不同。

我的问题是:我可能会面临一些问题compatibily?

+0

您使用哪条信息总线? –

+0

我正在使用兔子。 – Columb1a

回答

1

我使用的是兔子。

你应该确定即可;它将与新卡夫卡罐子源的/lib目录,因为每个模块在其自己的类加载器加载,所以应该与xd/lib罐没有发生冲突可能工作。

但是,您可能必须从xd/lib目录中删除旧的卡夫卡罐子(这就是为什么我问的消息总线)。