Confluent レジストリからのスキーマのインポート

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

始める前に

• 必要なロール：kafka_admin
• この機能は、ストリームコネクトのスキーマ管理に含まれています。詳細については、「ストリームコネクトでのスキーマ管理」を参照してください。
• ServiceNow Stream Connect Installer [com.glide.hub.stream_connect.installer] プラグインが必要です。
• スキーマをインポートするには、Confluent レジストリに接続するための接続および資格情報エイリアスが必要です。移動先 すべて > 統合ハブ > スキーマ管理 > 接続を設定 エイリアスを設定します。手順については、「Create a Connection & Credential alias」を参照してください。

このタスクについて

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

このドキュメントでは、Confluent レジストリからスキーマをインポートする方法を説明します。ストリームコネクトでのスタンドアロンスキーマの作成することもできます。

手順

1. 移動先 すべて > 統合ハブ > スキーマ管理 > Confluent Registry からスキーマをインポート.
2. Confluent レジストリからインポートするスキーマのタイトルを選択します。
3. インポートするスキーマのバージョンを選択します。
   最新のバージョンがデフォルトです。
4. [送信] をクリックします。
   Confluent ストリームコネクトスキーマフォームの [スキーマ] フィールドにはレジストリからインポートした JSON 形式のスキーマが、[スキーマ ID] フィールドにはスキーマの ID が設定されます。

タスクの結果

スキーマは、ストリームコネクトスキーマ [stream_connect_schema] テーブルと Confluent ストリームコネクトスキーマ [confluent_stream_connect_schema] テーブルに表示されます。

次のタスク

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