Spring Integration - ActiveMQ to Kafka

Question

現在、ActiveMQからのメッセージを消費し、それをKafkaに公開するアダプタを作成しようとしています。

私はこれらの2つのメッセージングシステムを統合するためにバネ統合を使用することを考えています。

私の問題は、私のアプリケーションでは、多くのアプリケーションがレコードをactiveMQに公開するモデルのレジストリを維持しないということです。これらのjavax jmsメッセージを受け取って、kafkaメッセージにjmscorrelationIdを追加するような変換を実行したいとします。

また、kafka send/publishが成功した場合にのみ、アクティブなmqに確認応答を送信する必要があります。

spring統合を使用してactivemqに返信することはできますか？

春の統合は適していますか？

私の技術者は、Camel/Muleの使用を推奨していません。また、Kafka Connectソースを使用しようとしていたので、彼はKafka Connectを使用したくありません。

お勧めします。

Answer 1

Spring Integration Kafka拡張プロジェクトは、公開のためにsync modeを持ちます。これは、Kafkaが配信を確認する（または失敗時に例外をスローする）までスレッドをブロックします。

JMS受信ゲートウェイを使用して、JMSキューへの応答を返すことができます。

フローにトランスを追加してメッセージを変更することができます。