1

我有以下配置：

  • spring-integration-kafka 1.3.1.RELEASE
  • 我有一个自定义的 kafka-sink 和一个自定义的 kafka-source

我想要的配置：

  • 我想仍然将 Spring-integration-kafka 1.3.1.RELEASE 与我的自定义 kafka-sink 一起使用。
  • 我正在更改我的 kafka 源逻辑以使用 Spring-integration-kafka-2.1.0.RELEASE。我注意到实现消费者/生产者的方式与以前版本的 Spring-integration-kafka 不同。

我的问题是：我可以面对一些兼容性问题吗？

4

1 回答 1

1

我正在使用兔子。

那你应该没事；它可能会与源/lib目录中较新的 kafka jar 一起使用，因为每个模块都加载到自己的类加载器中，因此不应与xd/libjar 发生冲突。

但是，您可能必须从xd/lib目录中删除旧的 kafka jar（这就是我询问消息总线的原因）。

于 2017-04-04T17:18:41.267 回答