Spring Integration - ActiveMQ zu Kafka

Question

Ich versuche gerade, einen Adapter zu schreiben, der Nachrichten von ActiveMQ konsumieren und es zu Kafka veröffentlichen wird.

Ich denke daran, die Integration der beiden Messaging-Systeme mittels Federintegration zu realisieren.

Mein Problem ist, dass meine Anwendung keine Registrierung der Modelle, mit denen viele Anwendungen die Datensätze in ActiveMQ veröffentlichen wird. Ich möchte diese javax jms-Nachricht erhalten und möchte eine Transformation wie das Hinzufügen von jmscorrelationId in kafka-Nachricht durchführen.

Eine weitere Voraussetzung ist, dass die Bestätigung nur dann an active mq gesendet wird, wenn kafka send/publish erfolgreich ist.

Kann mit Federintegration an activemq zurückgesendet werden?

Wird die Federintegration eine gute Option sein?

Bitte beachten Sie, dass mein technischer Architekt Camel/Mule nicht unterstützt. Außerdem möchte er Kafka Connect nicht verwenden, da ich Kafka Connect Source verwenden wollte.

Bitte vorschlagen.

Answer 1

Das Spring Integration Kafka Erweiterungsprojekt hat eine sync mode für die Veröffentlichung, die den Thread blockiert, bis Kafka die Lieferung bestätigt (oder eine Ausnahme bei einem Fehler auslöst).

Das JMS-Gateway für eingehende Nachrichten kann verwendet werden, um eine Antwort an eine JMS-Warteschlange zurückzugeben.

Sie können Transformatoren (oder was auch immer) im Datenfluss hinzufügen, um die Nachricht zu ändern.