ストリームコネクトでのスタンドアロンスキーマの作成

  • リリースバージョン: Australia
  • 更新日 2026年03月12日
  • 所要時間：2分

    • スキーマを作成して、 ストリームコネクト プロデューサーとコンシューマーが Apache Avro 形式で Kafka メッセージを送受信できるようにします。

    始める前に

    • 必要なロール：kafka_admin
    • この機能は、 ストリームコネクト のスキーマ管理の一部です。詳細については、「ストリームコネクトでのスキーマ管理」を参照してください。
    • ServiceNow ストリームコネクトインストーラー [com.glide.hub.stream_connect.installer] プラグインが必要です。

    このタスクについて

    ストリームコネクト はスキーマを使用して、メッセージをプレーンテキストから Avro 形式に変換したり、その逆の変換を行ったりします。Avro 形式を使用することで、ペイロードのサイズを減らし、ローカルの Kafka インスタンスへの統合を簡素化できます。

    このドキュメントでは、JSON ファイルをアップロードするか、スキーマを JSON 形式の文字列として直接入力して、独自のスタンドアロンスキーマを作成する方法について説明します。Confluent レジストリからのスキーマのインポートすることもできます。

    手順

    1. 移動先 すべて > 統合ハブ > スキーマ管理 > スタンドアロンスキーマを作成.

      Avro スキーマを作成するフォームで、[スキーマ ID] の値が自動的に入力されます。提案された値を保持または変更できます。

      すべてのスキーマには、スキーマのグローバルな一意の識別子であるスキーマ ID があります。スタンドアロンスキーマの場合、スキーマ ID はローカルで生成され、インスタンス上で一意です。デフォルトでは、生成されるスキーマ ID の値は、インスタンスで使用可能な最大スキーマ ID の次の値です。たとえば、スキーマの ID 番号が 1 から 5 の場合、次に作成するスキーマのスキーマ ID は 6 になります。スキーマ ID はレジストリごとに一意です。たとえば、2 つのスキーマは、異なるレジストリにある限り、両方とも 1 つの ID を持つことができます。

    2. [ソース] フィールドで、次のいずれかを選択します。
      オプション 説明
      ファイル スキーマをインポートする JSON ファイルを選択します。インポートされると、ファイルの内容が [JSON スキーマ] フィールドに表示されます。
      Avro 形式の文字列 (JSON) スキーマを JSON 文字列形式で入力します。
    3. [Submit (送信)] をクリックします。
      スタンドアロンストリームコネクトスキーマフォームの [スキーマ] フィールドには、アップロードまたは入力した JSON 形式のスキーマがあります。

    タスクの結果

    スキーマは、スタンドアロンストリームコネクトスキーマ [standalone_stream_connect_schema] テーブルとストリームコネクトスキーマ [stream_connect_schema] テーブルに表示されます。

    次のタスク

    ストリームコネクトのプロデューサーとコンシューマーを使用して、Avro 形式でメッセージを送受信します。