如何將XML事件傳遞給Apache Kafka？

Question

我的組織中有一個集羣（2節點）CRM應用程序，它使用Spring集成框架（v2.2.0）在執行操作時發佈事件，例如，創建一個請求，創建一個客戶等等。 目前這些事件只是去了一個NULL通道，但是我想開始將它們轉發到在同一網絡上運行的Apache Kafka實例。從那裏我想對數據做進一步的處理和分析，以使用其他組件創建實時報告。

我已經看了一下spring-integration-kafka項目，但它似乎與應用程序使用的集成版本（我無法升級）不兼容。

我覺得我爲獲得這些事件卡夫卡的選項有：

1）發送事件到本地文件系統，並有卡夫卡從那裏提取數據。

2）將事件發送到中間JMS隊列，並從那裏獲取Kafka pull數據。

3）通過HTTP請求（直接將事件發送到卡夫卡？） 非常感謝

Answer 1

好吧，如果你不能升級，只是使KafkaProducerMessageHandler類的副本，並將其調整到當前的Spring集成版。最後，它只是一個MessageHandler從通用<int:outbound-channel-adapter>使用。

最後，您總是可以直接從Service Activator方法使用Kafka Producer API。

不幸的是，您的所有建議都不足，因爲它們包含額外的網絡通信層，同時我們所需要的只是直接發送給Kafka。