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

コンポーネントを設定

手順

  1. cTimerコンポーネントをダブルクリックし、[Component] (コンポーネント)タブで[Basic settings] (基本設定)ビューを開きます。下のように、オプションはデフォルト設定のままにしておきます。
  2. SetBodyAsJsonStringというラベルが付けられている最初のcSetBodyコンポーネントをダブルクリックし、[Component] (コンポーネント)タブで[Basic settings] (基本設定)ビューを開きます。
  3. [Language] (言語)ドロップダウンリストで[Constant] (定数)を選択し、メッセージボディとして[Expression] (式)フィールドに"{\"my_field1\": 1,\"my_field2\": 72438939,\"my_field3\": \"my demo Test message\"}"というJSON文字列を入力します。
  4. ConvertBodyToAvroというラベルが付けられている最初のcMapコンポーネントの[Component] (コンポーネント)タブをクリックし、[Basic settings] (基本設定)ビューを開きます。
  5. [Map Path] (マップパス)フィールドの横にある[...]ボタンをクリックし、"Avro/Sample_JSON_to_AVRO"マップを選択します。
  6. [Output Type] (出力タイプ)ドロップダウンリストから[Object] (オブジェクト)を選択します。
  7. ConvertBodyToJsonStringというラベルが付けられている2番目のcMapコンポーネントの[Component] (コンポーネント)タブをクリックし、[Basic settings] (基本設定)を開きます。
  8. [Map Path] (マップパス)フィールドの横にある[...]ボタンをクリックし、"Avro/Sample_AVRO_to_JSON"マップを選択します。
  9. [Output Type] (出力タイプ)ドロップダウンリストから[Byte Array] (バイト配列)を選択します。
  10. SendMessageToKafkaというラベルが付けられている最初のcKafkaコンポーネントをダブルクリックし、[Component] (コンポーネント)タブで[Basic settings] (基本設定)ビューを開きます。
  11. [Broker List] (ブローカーリスト)フィールドに"localhost:9092"と入力します。
    [Topic] (トピック)フィールドに"demo.AVRO"と入力します。
    [Serializer Class] (シリアライザークラス)フィールドに、"org.example.local_project.beansjar.kafka_avro_beans.KafkaAvroSerializerBean"と入力します。local_projectをTalendのプロジェクト名に置き換えます。
    その他のオプションはデフォルト設定のままにしておきます。
  12. [Component] (コンポーネント)タブの[Advanced settings] (詳細設定)ビューを開きます。
  13. [Kafka Properties] (Kafkaのプロパティ)フィールドで、"schemaRegistryURL"という名前と"localhost:8081"という値でパラメーターを追加します。
  14. ReceiveMessageFromKafkaというラベルが付けられている2番目のcKafkaコンポーネントをダブルクリックし、[Component] (コンポーネント)タブで[Basic settings] (基本設定)ビューを開きます。
  15. [Broker List] (ブローカーリスト)フィールドに"localhost:9092"と入力します。
    [Topic] (トピック)フィールドに"demo.AVRO"と入力します。
    その他のオプションはデフォルト設定のままにしておきます。
  16. [Component] (コンポーネント)タブの[Advanced settings] (詳細設定)ビューを開きます。
  17. [Kafka Properties] (Kafkaのプロパティ)フィールドに、"schemaRegistryURL"という名前と"localhost:8081"という値を持つパラメーターを1つ、そして"valueDeserializer"という名前と"org.example.local_project.beansjar.kafka_avro_beans.KafkaAvroDeserializerBean"という値を持つパラメーターを1つ追加します。local_projectをTalendのプロジェクト名に置き換えます。
  18. メッセージ交換をログするcLogコンポーネントはデフォルト設定のままにしておきます。
  19. Ctrl + Sを押してジョブを保存します。

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

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

こちらにフィードバックをお寄せください