Hitachi

Cosminexus V11 BPM/ESB基盤 サービスプラットフォーム 解説


2.12 Kafkaとの接続

サービスプラットフォームでは,Apache Kafkaと連携してメッセージの送受信をする機能を提供しています。メッセージの受信には,Kafka受付およびKafkaインバウンドアダプタを使用します。メッセージの送信には,Kafkaアダプタを使用します。

Apache Kafkaと連携したメッセージの送受信の流れを次の図に示します。

図2‒90 Apache Kafkaと連携したメッセージの送受信の流れ

[図データ]

メッセージの受信

図中の1.〜4.について説明します。

  1. Kafkaインバウンドアダプタが,Apache Kafkaからメッセージを取得します。

  2. Kafkaインバウンドアダプタが,取得したメッセージをKafka受付に渡します。

  3. Kafka受付が,ビジネスプロセスにメッセージを渡します。

  4. ビジネスプロセス内で,データ変換アクティビティなどを使用して,メッセージを編集します。

メッセージの送信

Kafkaアダプタは,ビジネスプロセスからのメッセージ送信要求に従って,Apache Kafkaにメッセージを送信します。

〈この節の構成〉