5.2. Kafka トピックの設定
Kafka は トピック に関するメッセージを整理します。各トピックには名前があります。アプリケーションは、トピックにメッセージを送信し、トピックからメッセージを取得します。Kafka トピックは、Kafka インスタンスのデータの保存先を提供します。データを送信する前に、Kafka トピックを設定する必要があります。
前提条件
- Apache Kafka の概念を理解している。
- 適切なアクセスレベルで OpenShift クラスターにアクセスできること。この場合、プロジェクトの作成および Operator のインストールができること。また、OpenShift および Camel K CLI をローカルシステムにインストールできること。
-
「Preparing your OpenShift cluster」の手順に従って、OpenShift CLI (
oc) および Camel K CLI (kamel) ツールをインストールしている。 - 「Preparing your OpenShift cluster」の手順に従って、Red Hat Integration - Camel K Operator をインストールしている。
手順
Red Hat OpenShift Streams for Apache Kafka を使用して Kafka トピックを設定するには、以下を行います。
- コマンドラインから OpenShift クラスターにログインします。
以下のように、kamelets で Kafka に接続するプロジェクトを開きます。
oc project my-camel-k-kafka
必要な Operator がプロジェクトにインストールされていることを確認します。
oc get csv
結果には、Red Hat Camel K および RHOAS Operator が表示され、それらが
Succeededフェーズにあることを示します。Kafka インスタンスを準備し、RHOAS に接続します。
以下のコマンドを使用して RHOAS CLI にログインします。
rhoas login
kafka-test などの kafka インスタンスを作成します。
rhoas kafka create kafka-test
Kafka インスタンスを作成するプロセスの完了に数分かかる場合があります。
Kafka インスタンスのステータスを確認するには、以下を実行します。
rhoas status
Web コンソール https://cloud.redhat.com/beta/application-services/streams/kafkas/ でステータスを表示することもできます。ステータスが ready の場合は、次の手順に進みます。
新しい Kafka トピックを作成します。
rhoas kafka topic create test-topic
