Apache Kafkaトピックからのメッセージの消費
予定済のオーケストレートされた統合を構成して、「Apache Kafkaアダプタ」を使用して特定の間隔でApache Kafkaトピックからのメッセージを消費し、子統合(データベース表にレコードを挿入するためのOracle Databaseベースの統合など)を起動して、消費されたメッセージを処理できます。
次の統合は、このパターンの実装方法の一例です:
- 10分ごとに実行される、スケジュール済のオーケストレートされた統合。
- スケジュールと「Apache Kafkaアダプタ」の間で適切なソースからターゲットへのマッピングを実行するマッパー。
- 「Apache Kafkaアダプタ」の構成は次のとおりです:
- Kafkaトピックのレコードを消費します。
- アタッチするコンシューマ・グループを指定します。 Kafkaは、トピックのパーティションをグループ内のコンシューマに割り当てます。
- メッセージを使用するオプションとして「最新の読取り」を指定します。 最新のメッセージは、統合がアクティブ化された時点から読み込まれます。
- 使用するメッセージ構造(この例では、XMLスキーマ(XSD)ドキュメント)とメッセージに使用するヘッダーを指定します。
- 「Apache Kafkaアダプタ」とSOAPアダプタの間で適切なソースとターゲット間のマッピングを実行するためのマッパー。
- Kafkaトピック・レコードをOracle Database表に挿入するために起動されるSOAPアダプタ。
完成した統合は次のようになります。
