メイン コンテンツをスキップする 補完的コンテンツへスキップ

スキーマレジストリー接続を設定

このタスクについて

オブジェクトのスキーマに関する情報(この場合はAvroレコード)を登録するためには、Talend Studioでスキーマレジストリーを設定する必要があります。スキーマレジストリーを使用できるようにするため、お使いのコンピューターで環境が設定されており実行中であることを確認してください。詳細は、公式ドキュメンテーションでInstalling and Configuring Schema Registryをご覧ください。

手順

  1. 読み取りジョブでtKafkaInputコンポーネントをダブルクリックし、[Advanced settings] (詳細設定)ビューに移動します。
    情報メモ注: この設定はtKafkaOutputコンポーネントにも適用されます。
  2. [Use schema registry] (スキーマレジストリーを使用)チェックボックスを選択し、次のパラメーターを入力してスキーマレジストリーに接続します。
    • Url: スキーマレジストリインスタンスURL ("https://localhost:8081"など)を入力します。
    • [Basic authentication] (基本認証): このチェックボックスをオンにして[Username] (ユーザー名)フィールドと[Password] (パスワード)フィールドに認証情報を入力し、お使いのスキーマレジストリインスタンスを認証します。
    • [Key deserializer] (キーデシリアライザー): ドロップダウンリストで[Custom] (カスタム)を選択し、"org.apache.kafka.common.serialization.ByteArrayDeserializer"というAvroデシリアライザーを入力します。サポートされているAvroデシリアライザーの詳細は、Confluentの公式ドキュメンテーションでAvro Schema Serializer and Deserializerをご覧ください。
    • [Value deserializer] (値デシリアライザー): ドロップダウンリストでAvroを選択します。
  3. お使いのコンピューターでスキーマレジストリーを起動します。詳細は、公式ドキュメンテーションでStarting Schema Registryをご覧ください。

このページは役に立ちましたか?

このページまたはコンテンツにタイポ、ステップの省略、技術的エラーなどの問題が見つかった場合はお知らせください。