如何将XML事件发送到Apache Kafka？

Question

在我的组织中有一个群集(2节点) CRM应用程序，它使用spring集成框架(v2.2.0)在执行操作时发布事件，例如创建请求、创建客户等。目前，这些事件只是转到空通道，但我想开始将它们转发到运行在同一网络上的Apache Kafka实例。从那里，我想对数据进行进一步的处理和分析，以使用其他组件创建实时报告。

我看过spring- integration -kafka项目，但它似乎与应用程序使用的spring集成版本不兼容(我无法升级)。

我认为我将这些活动带到Kafka的选择是：

1)向本地文件系统发送事件，并让Kafka从本地文件系统拉取数据。

2)将事件发送到中间JMS队列，并让Kafka从那里拉取数据。

3)通过HTTP请求将事件直接发送给Kafka (?)非常感谢

Answer 1

如果无法升级，只需复制KafkaProducerMessageHandler类并将其调整为当前的Spring Integration版本即可。最后，它只是一个从通用<int:outbound-channel-adapter>中使用的MessageHandler。

最后，您始终可以从服务激活器方法中直接使用Kafka Producer API。

不幸的是，你所有的建议都是不够的，因为它们包含了额外的网络通信层，同时我们所需要的只是直接发送给Kafka。