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
```
```
oc project my-camel-k-kafka
```
Copy to Clipboard Toggle word wrap
必要な Operator がプロジェクトにインストールされていることを確認します。
```
oc get csv
```
```
oc get csv
```
Copy to Clipboard Toggle word wrap
結果には、Red Hat Camel K および RHOAS Operator が表示され、それらが Succeeded フェーズにあることを示します。
Kafka インスタンスを準備し、RHOAS に接続します。
1. 以下のコマンドを使用して RHOAS CLI にログインします。
  rhoas login
  Copy to Clipboard Toggle word wrap
2. kafka-test などの kafka インスタンスを作成します。
  rhoas kafka create kafka-test
  Copy to Clipboard Toggle word wrap
  Kafka インスタンスを作成するプロセスの完了に数分かかる場合があります。
Kafka インスタンスのステータスを確認するには、以下を実行します。
```
rhoas status
```
```
rhoas status
```
Copy to Clipboard Toggle word wrap
Web コンソール https://cloud.redhat.com/beta/application-services/streams/kafkas/ でステータスを表示することもできます。ステータスが ready の場合は、次の手順に進みます。
新しい Kafka トピックを作成します。
```
rhoas kafka topic create test-topic
```
```
rhoas kafka topic create test-topic
```
Copy to Clipboard Toggle word wrap

トップに戻る

5.2. Kafka トピックの設定

詳細情報

試用、購入および販売

コミュニティー

Red Hat ドキュメントについて

多様性を受け入れるオープンソースの強化

会社概要

Theme

Red Hat legal and privacy links

Red Hat legal and privacy links