スキーマレジストリーを使ってAvroメッセージを読み取る

スキーマレジストリーを使ってAvro形式のメッセージを読み取れるよう、tKafkaInputAvroを設定するために使われます。

1. tKafkaInputAvroをダブルクリックして[Component] (コンポーネント)ビューを開きます。
2. [Edit schema] (スキーマを編集)の横にあるボタンをクリックし、スキーマダイアログボックスを開いてスキーマを定義します。このシナリオでのスキーマはAvroスキーマと同じものであることが必要です。

   

   完了したら、[OK]をクリックして変更を保存し、スキーマダイアログボックスを閉じます。
3. [Broker list] (ブローカーリスト)フィールドに、使うKafkaクラスターのブローカーのロケーションを入力します。ロケーションはコンマ(,)で区切ります。このシナリオに存在するブローカーは1つだけで、そのロケーションはlocalhost:9093です。
4. [Starting offset] (開始オフセット)ドロップダウンリストから、トピックのメッセージが消費される開始点を選択します。このシナリオでは、トピック全体の最古のメッセージから開始する[From beginning] (最初から)を選択します。
5. [Topic name] (トピック名)フィールドに、このジョブが消費するフライト情報の元であるトピックの名前を入力します。このシナリオでのトピックはflightsTopicです。
6. [Group id] (グループID)フィールドに、このジョブが消費するフライト情報の元であるグループのIDを入力します。このシナリオでのトピックはmyFlightsGroupです。
7. [Use SSL/TLS] (SSL/TLSを使用)チェックボックスをオンにし、ジョブで以前構成したtSetKeystoreコンポーネントをtSetKeystoreドロップダウンリストから選択します。このシナリオでのコンポーネントはtSetKeystore_1です。
8. [Use Schema Registry] (スキーマレジストリーを使用)チェックボックスをオンにし、次のパラメーターを設定するために使われます。
   1. Url: スキーマレジストリインスタンスURLを入力します。このシナリオでのURLはhttps://localhost:8085です。
   2. [Basic authentication] (基本認証): このチェックボックスをオンにして、[Username] (ユーザー名)フィールドと[Password] (パスワード)フィールドに認証情報を入力します。
   3. [Set schema registry keystore] (スキーマレジストリーのキーストアを設定): このチェックボックスをオンにしてSSLまたはTLS暗号化接続を有効にし、ジョブで以前構成したtSetKeystoreコンポーネントをtSetKeystoreドロップダウンリストで選択します。このシナリオのコンポーネントはtSetKeystore_1ですが、スキーマレジストリーで別のキーストアファイルを使う場合は、2番目のtSetKeystoreコンポーネントを使用することもできます。