2.2. 设置 Kafka

设置 Kafka 涉及安装所需的 OpenShift operator、创建 Kafka 实例并创建 Kafka 主题。

使用其中一个红帽产品来设置 Kafka：

Red Hat Advanced 消息队列(AMQ)流 - 自我管理的 Apache Kafka 产品。AMQ Streams 基于开源 Strimzi，并包含在 Red Hat Integration 中。AMQ Streams 是一个基于 Apache Kafka 的分布式、可扩展的流平台，其中包含发布/订阅消息传递代理。Kafka Connect 提供了一个框架，用于将基于 Kafka 的系统与外部系统集成。使用 Kafka Connect，您可以配置 source 和 sink 连接器，将来自外部系统的数据流传输到 Kafka 代理中。
Red Hat OpenShift Streams for Apache Kafka - 受管云服务，简化了运行 Apache Kafka 的过程。它为构建、部署和扩展新的云原生应用程序或现代化现有系统提供了简化的开发人员体验。

AMQ Streams 简化了在 OpenShift 集群中运行 Apache Kafka 的过程。

要使用 Camel K 或 Kamelets 和 Red Hat AMQ Streams，您必须安装以下操作器和工具：

Red Hat Integration - AMQ Streams operator - 管理 Openshift Cluster 和 AMQ Streams for Apache Kafka 实例之间的通信。
Red Hat Integration - Camel K operator - 安装和管理 Camel K - 一个轻量级集成框架，它在 OpenShift 上的云中原生运行。
Camel K CLI 工具 - 允许您访问所有 Camel K 功能。

先决条件

熟悉 Apache Kafka 概念。
您可以使用正确的访问级别访问 OpenShift 4.6 （或更新版本）集群、创建项目并安装 Operator，以及在本地系统中安装 OpenShift 和 Camel K CLI 的功能。
已安装 OpenShift CLI 工具(oc)，以便您可以在命令行中与 OpenShift 集群交互。

流程

使用 AMQ Streams 设置 Kafka：

登录您的 OpenShift 集群的 Web 控制台。
创建或打开您要在其中创建集成的项目，如 my-camel-k-kafka。
安装 Camel K operator 和 Camel K CLI，如安装 Camel K 所述。
安装 AMQ 流 Operator：
1. 在任何项目中，选择 Operators > OperatorHub。
2. 在 Filter by Keyword 字段中，键入 AMQ Streams。
3. 点 Red Hat Integration - AMQ Streams 卡，然后点 Install。
  此时会打开 Install Operator 页面。
4. 接受默认值，然后点 Install。
选择 Operators > Installed Operators 来验证是否安装了 Camel K 和 AMQ Streams operator。

后续步骤

使用 AMQ Streams 设置 Kafka 主题

Kafka 主题提供 Kafka 实例中数据存储的目的地。您必须在向它发送数据前设置 Kafka 主题。

先决条件

您可以访问 OpenShift 集群。
已安装 Red Hat Integration - Camel K 和 Red Hat Integration - AMQ Streams operator，如准备 OpenShift 集群中所述。
已安装 OpenShift CLI (oc)和 Camel K CLI (kamel)。

流程

使用 AMQ Streams 设置 Kafka 主题：

登录您的 OpenShift 集群的 Web 控制台。
选择 Projects，然后点安装 Red Hat Integration - AMQ Streams operator 的项目。例如，点 my-camel-k-kafka 项目。
选择 Operators > Installed Operators，然后点 Red Hat Integration - AMQ Streams。
创建 Kafka 集群：
1. 在 Kafka 下，点 Create instance。
2. 为集群输入名称，如 kafka-test。
3. 接受其他默认值，然后单击 Create。
  创建 Kafka 实例的过程可能需要几分钟时间完成。
  当状态就绪时，请继续下一步。
创建 Kafka 主题：
1. 选择 Operators > Installed Operators，然后点 Red Hat Integration - AMQ Streams。
2. 在 Kafka Topic 下，点 Create Kafka Topic。
3. 为主题输入名称，如 test-topic。
4. 接受其他默认值，然后单击 Create。