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

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

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

このシナリオでルートを作成する前に、次の前提条件を満たしていることを確認してください。

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のドキュメンテーションをご覧ください。

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

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