在我的组织中有一个集群（2节点）crm应用程序，它使用spring集成框架（v2.2.0）在执行操作时发布事件，例如创建请求，创建一个客户等目前这些事件只是去一个空通道，但我想开始转发它们到一个ApacheKafka在同一个网络上运行的示例。从那里我想做进一步的数据处理和分析，以创建使用其他组件的实时报告。
我看了一下SpringIntegrationKafka项目，但它似乎与应用程序使用的SpringIntegration版本不兼容（我无法升级）。
我想我把这些活动带到Kafka的选择是：
1） 将事件发送到本地文件系统，并让kafka从中提取数据。
2） 将事件发送到中间jms队列，并让kafka从那里提取数据。
3） 通过http请求将事件直接发送给kafka（？）非常感谢
1条答案
按热度按时间dsekswqp1#
好吧，如果你不能升级，就复制一份
KafkaProducerMessageHandler类并将其调整为当前的spring集成版本。最后它只是一个MessageHandler从泛型中使用<int:outbound-channel-adapter>.最后你可以用Kafka
Producer直接从服务激活器方法获取api。不幸的是你的建议是不够的，因为他们包括额外的网络通信层，同时我们只需要直接发送到Kafka。