2.2. 设置 Kafka

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

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

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

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

要使用 Camel K 或 Kamelets 和红帽 AMQ Streams，您必须安装以下操作程序和工具：

Red Hat Integration - AMQ Streams operator - 管理 Openshift Cluster 和 Apache Kafka 实例的 AMQ Streams 之间的通信。
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 Topic 下，点击 Create Kafka Topic。
3. 为主题输入一个名称，如 test-topic。
4. 接受其他默认值，然后点 Create。