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

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

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

Talendがサポートしているテクノロジーの詳細は、Talend Mediationコンポーネントをご覧ください。

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

このシナリオでルートを作成する前に、次の前提条件を満たしていることを確認してください。
  • 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のドキュメンテーションをご覧ください。

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

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