SpringXD/Spring Integration：生产者和消费者使用不同版本的spring-integration-kafka答案

【问题标题】：SpringXD/Spring Integration: Using different versions of spring-integration-kafka for producer and consumerSpringXD/Spring Integration：生产者和消费者使用不同版本的spring-integration-kafka
【发布时间】：2017-04-04 15:20:41
【问题描述】：

我有以下配置：

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 完全不同。

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

【问题讨论】：

您使用的是哪种消息总线？
我正在使用 Rabbit。

标签： apache-kafka spring-integration spring-xd spring-kafka

【解决方案1】：

我正在使用兔子。

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

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

【讨论】：