2.2. 设置 Kafka

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

使用这些红帽产品之一设置 Kafka：

Red Hat Advanced Message Queue (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，您必须安装以下 operator 和工具：

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

前提条件

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

流程

使用 AMQ Streams 设置 Kafka：

登录您的 OpenShift 集群的 Web 控制台。
创建或打开您要在其中创建集成的项目，如 my-camel-k-kafka。
安装 Camel K 运算符和 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 主题 下，点 Create Kafka Topic。
3. 输入主题的名称，如 test-topic。
4. 接受其他默认值，然后单击 Create。