2.2.2.2. RHOAS を使用した Kafka トピックの設定
Kafka は トピック に関するメッセージを整理します。各トピックには名前があります。アプリケーションは、トピックにメッセージを送信し、トピックからメッセージを取得します。Kafka トピックは、Kafka インスタンスのデータの保存先を提供します。データを送信する前に、Kafka トピックを設定する必要があります。
前提条件
- 適切なアクセスレベルで OpenShift クラスターにアクセスできること。この場合、プロジェクトの作成および Operator のインストールができること。また、OpenShift および Camel K CLI をローカルシステムにインストールできること。
-
OpenShift クラスターの準備 の手順に従って、OpenShift CLI (
oc)、Camel K CLI (kamel)、および RHOAS CLI (rhoas) ツールをインストールしている。 - OpenShift クラスターの準備 の説明どおりに、Red Hat Integration - Camel K Operator がインストールされている。
- Red Hat Cloud サイト にログインしている。
手順
Red Hat OpenShift Streams for Apache Kafka を使用して Kafka トピックを設定するには、以下を行います。
- コマンドラインから OpenShift クラスターにログインします。
プロジェクトを開きます。以下に例を示します。
oc project my-camel-k-kafkaCamel K Operator がプロジェクトにインストールされていることを確認します。
oc get csv結果には、Red Hat Camel K Operator が表示され、それが
Succeededフェーズにあることを示します。Kafka インスタンスを準備し、RHOAS に接続します。
以下のコマンドを使用して RHOAS CLI にログインします。
rhoas loginkafka-test などの kafka インスタンスを作成します。
rhoas kafka create kafka-testKafka インスタンスを作成するプロセスの完了に数分かかる場合があります。
Kafka インスタンスのステータスを確認するには、以下を実行します。
rhoas statusWeb コンソールでステータスを表示することもできます。
https://cloud.redhat.com/application-services/streams/kafkas/
ステータスが ready になったら、次のステップに進みます。
新しい Kafka トピックを作成します。
rhoas kafka topic create --name test-topicKafka インスタンス (クラスター) を Openshift Application Services インスタンスに接続します。
rhoas cluster connectクレデンシャルトークンを取得するスクリプトの手順に従います。
以下のような出力が表示されるはずです。
Token Secret "rh-cloud-services-accesstoken-cli" created successfully Service Account Secret "rh-cloud-services-service-account" created successfully KafkaConnection resource "kafka-test" has been created KafkaConnection successfully installed on your cluster.
次のステップ
