2.2.2.2. 使用 RHOAS 设置 Kafka 主题
Kafka 围绕 主题 组织信息。每个主题都有一个名称。应用程序将消息发送到主题并检索来自主题的消息。Kafka 主题为 Kafka 实例中数据存储提供目的地。您必须设置 Kafka 主题,然后才能将数据发送到它。
先决条件
- 您可以使用正确的访问级别访问 OpenShift 集群,以及创建项目和安装操作器,以及在本地系统上安装 OpenShift 和 Camel K CLI 的功能。
-
安装 OpenShift CLI(
oc
)、Camel(kamel
)和 RHOAS CLI(rhoas
)工具,如 准备 OpenShift 集群 中所述。 - 安装 Red Hat Integration - Camel K operator,如 准备 OpenShift 集群 所述。
- 登录到 Red Hat Cloud 网站。
流程
使用 Red Hat OpenShift Streams for Apache Kafka 设置 Kafka 主题:
- 从命令行,登录您的 OpenShift 集群。
打开您的项目,例如:
oc project my-camel-k-kafka
验证项目中是否安装了 Camel K Operator:
oc get csv
结果列出了 Red Hat Camel K operator,并表示它处于
Succeeded
阶段。准备并将 Kafka 实例连接到 RHOAS:
使用以下命令登录到 RHOAS CLI:
RHOAS 登录
创建一个 kafka 实例,如 kafka-test :
RHOAS kafka 创建 kafka-test
创建 Kafka 实例的过程可能需要几分钟时间。
检查 Kafka 实例的状态:
RHOAS 状态
您还可以在 web 控制台中查看状态:
https://cloud.redhat.com/application-services/streams/kafkas/
状态 就绪时,请继续下一步。
创建新的 Kafka 主题:
RHOAS kafka 主题创建 --name test-topic
将 Kafka 实例(集群)与 Openshift Application Services 实例连接:
RHOAS 集群连接
按照获取凭据令牌的脚本说明。
您应该看到类似如下的输出:
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.
后续步骤