Apache Kafkaトピックへのメッセージの生成
「FTPアダプタ」およびステージ・ファイル読取りアクションを使用して、スケジュールされたオーケストレートされた統合を構成してレコードを読み取り、「Apache Kafkaアダプタ」の生成操作を使用して、Apache Kafkaトピックに公開できます。
次の統合は、このパターンの実装方法の一例です:
- 1回実行される、スケジュール済のオーケストレートされた統合。
- スケジュールとFTPアダプタ間の適切なソースからターゲットへのマッピングを実行するマッパー。
- 入力ディレクトリからファイル(レコード)をフェッチし、ダウンロード・ディレクトリに配置するFTPアダプタ。
- 次のものに構成されたステージ・ファイル・アクション:
- ダウンロード・ディレクトリ内の各ファイル(レコード)に対して「セグメント内のファイルの読み取り」操作を実行します。
- 使用するメッセージのコンテンツの構造(この例では、XMLスキーマ(XSD)ドキュメント)を指定します。
- ステージ・ファイル・アクションと「Apache Kafkaアダプタ」との間で、適切なソースからターゲットへのマッピングを実行します。
- 「Apache Kafkaアダプタ」の構成は次のとおりです:
- Kafkaトピックにレコードを公開します。
- 使用するメッセージ構造(この例では、XMLスキーマ(XSD)ドキュメント)とメッセージに使用するヘッダーを指定します。
- 「Apache Kafkaアダプタ」アダプタとFTPアダプタの間で適切なソースとターゲット間のマッピングを実行するマッパー。
- 処理が完了したら、ダウンロード・ディレクトリからファイルを削除するためのFTPアダプタです。
完成した統合は次のようになります。
