--- sourceDocument: Yokohama データと自動化 sourceDocumentLink: https://servicenow-prod.fluidtopics.net/r/ja-JP/yokohama/integrate-applications Release : - yokohama ft:locale : - ja-JP ft:publication_title : - Yokohama データと自動化 ft:clusterId : - crint bundleId : - crint workflow : - Creator --- # 抽出変換ロード (ETL) コンシューマーの構成 # 抽出変換ロード (ETL) コンシューマーの構成 {#ariaid-title1} * リリースバージョン: Yokohama * * 更新日 2025年01月30日 * * ![](https://www.servicenow.com/docs/portal-asset/ico-clock) 所要時間：3分 Kafka 環境からデータをインポートし、既存の強力な変換エンジン (RTE) 構成を使用してそのデータを処理します。 ## 始める前に * 必要なロール： integration_hub_admin * このコンシューマには ストリームコネクトサブスクリプションが必要です。詳細については、「」を参照してください。 * ServiceNow Stream Connect Installer \[com.glide.hub.stream_connect.installer\] プラグインが必要です。 * このコンシューマーには、[強力なインポートセットトランスフォーマー](https://servicenow-prod.fluidtopics.net/S5xYYwkowPeE73VrERe5~w "データを抽出、変換して 1 つ以上のターゲットテーブルにロードする場合は、変換マップの代わりに強力なインポートセットトランスフォーマーを使用します。")が必要です。 {#configure-etl-consumer__ul_ity_vdq_hvb} ## このタスクについて コンシューマーを設定するには、2 つのレコードを作成する必要があります。 1. データのインポート方法と処理方法を指定するコンシューマーレコード。 2. コンシューマーへのデータストリームを定義する Kafka ストリームのレコード。 {#configure-etl-consumer__ol_orv_nx1_mvb}このタスクでは、コンシューマーの作成について説明します。Kafka ストリームの作成方法については、「[Kafka ストリームの作成](https://servicenow-prod.fluidtopics.net/bfgmjteqZTCKAC4n1qfTRA "抽出変換ロード (ETL)、変換マップ、スクリプトコンシューマーのデータストリームを定義します。Kafka ストリームは、コンシューマーへのデータのストリームを定義します。")」を参照してください。 ## 手順 1. 移動先 すべて統合ハブコンシューマーETL コンシューマー. 2. \[新規\] を選択します。 3. フォームのフィールドに入力します。 {#configure-etl-consumer__table_wvt_wgq_hvb__entry__2} | フィールド | 説明 | |-|-| | 名前 | ETL コンシューマーの名前。 | | 強力なインポートセットトランスフォーマー | データの処理に使用する強力なインポートセットトランスフォーマーの名前。 | | 配送保証 | ノード障害が発生した場合に、受信メッセージの配信保証を指定するオプション。次のいずれかを選択します。 * 紛失なし、重複なし：すべてのメッセージが少なくとも 1 回配信されます。一部のメッセージは複数回配信される可能性があります。 * 一度、またはまったくない：メッセージは複数回配信されません。一部のメッセージがまったく配信されない可能性があります。 {#configure-etl-consumer__ul_br1_bmq_hvb} | | シリアル化形式 | メッセージのシリアル化形式。次のいずれかを選択します。 * プレーンテキスト：プレーンテキストメッセージの場合は、このオプションを選択します。これがデフォルトの形式です。 * エンコード済み：Apache Avro 形式のメッセージには、このオプションを選択します。プレーンテキストメッセージを Avro 形式に変換するには、スキーマが必要です。\[スキーマレジストリ\] フィールドでスキーマレジストリを選択します。スキーマの詳細については、「[ストリームコネクトのスキーマ管理](https://servicenow-prod.fluidtopics.net/wz17c0NZ4X2PQaAu2Jl6bw "スキーマをインポートして作成し、Apache Avro 形式でメッセージを送受信します。Avro 形式を使用することで、ペイロードのサイズを減らし、ローカルの Kafka インスタンスへの統合を簡素化できます。")」を参照してください。 {#configure-etl-consumer__ul_svj_dgf_gbc} | | 単一列のデータ | 単一列にインポートセットテーブルを格納させるオプション。 | | 列マッピング | メッセージの JSON キーがデータをインポートセットテーブルの列の名前またはラベルにマッピングするかどうかを指定するオプション。次のいずれかを選択します。 * ラベル * 列名 {#configure-etl-consumer__ul_a1b_2mq_hvb}このフィールドは、\[単一列のデータ\] チェックボックスがオフの場合にのみ表示されます。 | | アプリケーション | ETL コンシューマーのアプリケーションスコープ。 | | スキーマレジストリ | 選択したスキーマのレジストリ。次のいずれかを選択します。 * スタンドアロンのスキーマレジストリ * Confluent Schema Registry {#configure-etl-consumer__ul_gsw_qff_gbc} このフィールドは、\[シリアル化形式\] が \[エンコード済み\] に設定されている場合にのみ表示されます。 Confluent Schema Registry では、受信したメッセージのスキーマ ID がスキーマテーブルにない場合、構成された REST 接続を使用してスキーマが動的にインポートされます。 | [表 : 1. Kafka ETL コンシューマー] {#configure-etl-consumer__table_wvt_wgq_hvb} 4. \[保存\] をクリックします。 ## 次のタスク このコンシューマーの [Kafka ストリームの作成](https://servicenow-prod.fluidtopics.net/bfgmjteqZTCKAC4n1qfTRA "抽出変換ロード (ETL)、変換マップ、スクリプトコンシューマーのデータストリームを定義します。Kafka ストリームは、コンシューマーへのデータのストリームを定義します。")。ストリームがアクティブ化されると、Kafka 環境からのメッセージの受信を開始できます。