Apache Kafkaでこれを実現するにはどうすればよいですか

Question

Apacke Kafkaを介して2つの下流システムを使用しているときにトランザクションデータを送信し、UIに成功メッセージを表示する前に、ダウンストリームシステム。

私たちはプロデューサを介してデータをプッシュし、消費者側でデータを読み込み、ダウンストリームシステムに保存することができます。欠落しているリンクは、ダウンストリームシステムでデータが正常に保存されたかどうかを知ることで、UIに成功メッセージを表示できるようにする方法です。

私たちがカフカを通じて達成できる方法はありますか？私たちはkafkaの使用を開始したばかりですが、このユースケースがkafkaに適合するかどうかは不明です。

Answer 1

消費者が消費者を知っている場合、消費されたレコードを確認するためにコミットされたコンシューマのオフセットを観察できます。プロデューサは、それ自体が書き込んだメッセージにそれらのオフセットをマップすることができます。

これを行う方法（1つの質問の範囲を超えた方法）については、Kafkaコード（オープンソース）を掘り下げてください。開始点として、消費者のオフセットを監視するツールであるbin/kafka-consumer-groups.shを参照してください。