---
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


---

# 変換マップコンシューマーの構成

# 変換マップコンシューマーの構成 {#ariaid-title1}

* リリースバージョン: Yokohama
* 
* 更新日 2025年01月30日
* 
* ![](https://www.servicenow.com/docs/portal-asset/ico-clock) 所要時間：3分

既存の変換マップ構成を使用して、Kafka 環境からデータをインポートして処理します。

## 始める前に

* 必要なロール： integration_hub_admin
* このコンシューマには ストリームコネクトサブスクリプションが必要です。詳細については、「<https://www.servicenow.com/now-platform/workflow-data-fabric.html>」を参照してください。
* ServiceNow Stream Connect Installer \[com.glide.hub.stream_connect.installer\] プラグインが必要です。
* このコンシューマーには、[変換マップ](https://servicenow-prod.fluidtopics.net/RPXxiBEruFYNmW1p2od7Yw "変換マップは、インポートセットのフィールドと、インシデント [incident] やユーザー [sys_user] などの既存の ServiceNow テーブルのフィールドとの関係を決定するフィールドマップのセットです。")が必要です。
{#configure-transform-map-consumer__ul_mcl_f4x_hvb}

## Kafka メッセージペイロードのフォーマット {#configure-transform-map-consumer__section_dsk_hwt_pfc}

Kafka メッセージにはシンプルな JSON ペイロードを使用します。各 Kafka メッセージには、フラットな JSON オブジェクトが 1 つだけ含まれている必要があります。リストやネストされたオブジェクトを含むような複雑な JSON ペイロードはサポートされていません。  
キーと値のペアのフラットマップを使用した、シンプルで有効な JSON 入力の例。

    {"key1": "value1", "key2": "value2"}

複雑で無効な JSON 入力の例。1 つ目はリストを使用します。2 つ目は、ネストされたオブジェクトを使用します。

    [{"key1": "value1", "key2": "value2"}, {"key1": "value3", "key2": "value4"}]

    {"key1": "value1", "key2": {"key3": "value3", "key4": "value4"}}

## このタスクについて

コンシューマーを設定するには、2 つのレコードを作成する必要があります。

1. データのインポート方法と処理方法を指定するコンシューマーレコード。
2. コンシューマーへのデータストリームを定義する Kafka ストリームのレコード。

{#configure-transform-map-consumer__ol_orv_nx1_mvb}このタスクでは、コンシューマーの作成について説明します。Kafka ストリームの作成方法については、「[Kafka ストリームの作成](https://servicenow-prod.fluidtopics.net/bfgmjteqZTCKAC4n1qfTRA "抽出変換ロード (ETL)、変換マップ、スクリプトコンシューマーのデータストリームを定義します。Kafka ストリームは、コンシューマーへのデータのストリームを定義します。")」を参照してください。

## 手順

1. 移動先 すべて統合ハブコンシューマー変換マップコンシューマー.
2. \[新規\] を選択します。
3. フォームのフィールドに入力します。  
   {#configure-transform-map-consumer__table_v2m_wlq_hvb__entry__2}

   | フィールド | 説明 |
   |-|-|
   | 名前 | 変換マップコンシューマーの名前。 |
   | 変換マップ | データの処理に使用する変換マップの名前。 |
   | 配送保証 | ノード障害が発生した場合に、受信メッセージの配信保証を指定するオプション。次のいずれかを選択します。 * 紛失なし、重複なし：すべてのメッセージが少なくとも 1 回配信されます。一部のメッセージは複数回配信される可能性があります。 * 一度、またはまったくない：メッセージは複数回配信されません。一部のメッセージがまったく配信されない可能性があります。 {#configure-transform-map-consumer__ul_ojr_cmq_hvb} |
   | シリアル化形式 | メッセージのシリアル化形式。次のいずれかを選択します。 * プレーンテキスト：プレーンテキストメッセージの場合は、このオプションを選択します。これがデフォルトの形式です。 * エンコード済み：Apache Avro 形式のメッセージには、このオプションを選択します。プレーンテキストメッセージを Avro 形式に変換するには、スキーマが必要です。\[スキーマレジストリ\] フィールドでスキーマレジストリを選択します。スキーマの詳細については、「[ストリームコネクトのスキーマ管理](https://servicenow-prod.fluidtopics.net/wz17c0NZ4X2PQaAu2Jl6bw "スキーマをインポートして作成し、Apache Avro 形式でメッセージを送受信します。Avro 形式を使用することで、ペイロードのサイズを減らし、ローカルの Kafka インスタンスへの統合を簡素化できます。")」を参照してください。 {#configure-transform-map-consumer__ul_svj_dgf_gbc} |
   | 列マッピング | メッセージの JSON キーがデータをインポートセットテーブルの列の名前またはラベルにマッピングするかどうかを指定するオプション。次のいずれかを選択します。 * ラベル * 列名 {#configure-transform-map-consumer__ul_rch_fmq_hvb} |
   | 挿入を同期する | レコード挿入を同期することで、一意の結合フィールド値を持つ 1 つのレコードのみを保証するオプション。 |
   | アプリケーション | 変換マップコンシューマーのアプリケーションスコープ。 |
   | スキーマレジストリ | 選択したスキーマのレジストリ。次のいずれかを選択します。 * スタンドアロンのスキーマレジストリ * Confluent Schema Registry {#configure-transform-map-consumer__ul_gsw_qff_gbc} このフィールドは、\[シリアル化形式\] が \[エンコード済み\] に設定されている場合にのみ表示されます。 Confluent Schema Registry では、受信したメッセージのスキーマ ID がスキーマテーブルにない場合、構成された REST 接続を使用してスキーマが動的にインポートされます。 |
   [表 : 1. Kafka 変換マップコンシューマー]

   {#configure-transform-map-consumer__table_v2m_wlq_hvb}
4. \[保存\] をクリックします。

## 次のタスク

このコンシューマーの [Kafka ストリームの作成](https://servicenow-prod.fluidtopics.net/bfgmjteqZTCKAC4n1qfTRA "抽出変換ロード (ETL)、変換マップ、スクリプトコンシューマーのデータストリームを定義します。Kafka ストリームは、コンシューマーへのデータのストリームを定義します。")。ストリームがアクティブ化されると、Kafka 環境からのメッセージの受信を開始できます。