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

  • リリースバージョン: Australia
  • 更新日 2026年03月12日
  • 所要時間：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] プラグインが必要です。
    • このコンシューマーには、変換マップが必要です。

    Kafka メッセージペイロードのフォーマット

    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 ストリームのレコード。
    このタスクでは、コンシューマーの作成について説明します。Kafka ストリームの作成方法については、「Kafka ストリームの作成」を参照してください。

    手順

    1. 移動先 すべて > 統合ハブ > コンシューマー > 変換マップコンシューマー.
    2. [新規] を選択します。
    3. フォームのフィールドに入力します。
      表 : 1. 変換マップコンシューマー
      フィールド 説明
      名前 変換マップコンシューマーの名前。
      変換マップ データの処理に使用する変換マップの名前。
      配送保証 ノード障害が発生した場合に、受信メッセージの配信保証を指定するオプション。次のいずれかを選択します。
      • 紛失なし、重複なし：すべてのメッセージが少なくとも 1 回配信されます。一部のメッセージは複数回配信される可能性があります。
      • 一度、またはまったくない：メッセージは複数回配信されません。一部のメッセージがまったく配信されない可能性があります。
      シリアル化形式 メッセージのシリアル化形式。次のいずれかを選択します。
      • プレーンテキスト：プレーンテキストメッセージの場合は、このオプションを選択します。これがデフォルトの形式です。
      • エンコード済み：Apache Avro 形式のメッセージには、このオプションを選択します。プレーンテキストメッセージを Avro 形式に変換するには、スキーマが必要です。[スキーマレジストリ] フィールドでスキーマレジストリを選択します。スキーマの詳細については、「ストリームコネクトでのスキーマ管理」を参照してください。
      列マッピング メッセージの JSON キーがデータをインポートセットテーブルの列の名前またはラベルにマッピングするかどうかを指定するオプション。次のいずれかを選択します。
      • ラベル
      • 列名
      挿入を同期する レコード挿入を同期することで、一意の結合フィールド値を持つ 1 つのレコードのみを保証するオプション。
      アプリケーション 変換マップコンシューマーのアプリケーションスコープ。
      スキーマレジストリ
      選択したスキーマのレジストリ。次のいずれかを選択します。
      • スタンドアロンのスキーマレジストリ
      • Confluent Schema Registry

      このフィールドは、[シリアル化形式] が [エンコード済み] に設定されている場合にのみ表示されます。

      Confluent Schema Registry では、受信したメッセージのスキーマ ID がスキーマテーブルにない場合、構成された REST 接続を使用してスキーマが動的にインポートされます。
    4. [保存] をクリックします。

    次のタスク

    このコンシューマーの Kafka ストリームの作成。ストリームがアクティブ化されると、Kafka 環境からのメッセージの受信を開始できます。