メイン コンテンツをスキップする

cKafkaを使ってConfluent Kafkaにアクセス

このシナリオは、Talend ESBTalend Data Services PlatformTalend MDM PlatformTalend Real-Time Big Data PlatformTalend Data Fabricにのみ適用されます。

このシナリオでは、スキーマレジストリーを使ったConfluent Kafkaメッセージブローカーとのメッセージ交換にcKafkaコンポーネントを使用する方法を紹介します。

このシナリオでルートを作成する前に、次の前提条件を満たしていることを確認してください。
  • Confluent KafkaのDockerイメージ一式をGitリポジトリーからダウンロード済みであること。
    git clone https://github.com/confluentinc/cp-all-in-one -b 7.1.0-post
  • Dockerが稼働していること。
  • ローカルのConfluent Kafka環境はDockerを使って起動されます:
    cd cp-all-in-one/cp-all-in-one
    docker-compose up

cKafkaコンポーネントの詳細は、Apache Camelのドキュメンテーションをご覧ください。

Apache KafkaとConfluent Kafkaの違いについては、Confluent Kafkaのドキュメンテーションをご覧ください。

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

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