第 4 章 AMQ Streams Operator
AMQ Streams 支持使用 Operator 的 Kafka 来部署和管理 Kafka 到 OpenShift 的组件和依赖项。
Operator 是一种打包、部署和管理 OpenShift 应用的方法。AMQ Streams Operator 扩展 OpenShift 功能，自动执行与 Kafka 部署相关的常见复杂任务。通过在代码中了解 Kafka 操作，Kafka 管理任务可以简化，无需人工干预。
Operator
AMQ Streams 提供 Operator 来管理在 OpenShift 集群中运行的 Kafka 集群。
- Cluster Operator
- 部署和管理 Apache Kafka 集群、Kafka Connect、Kafka MirrorMaker、Kafka Bridge、Kafka Exporter 和 Entity Operator
- 实体 Operator
- 由主题 Operator 和 User Operator 组成
- 主题 Operator
- 管理 Kafka 主题
- User Operator
- 管理 Kafka 用户
Cluster Operator 可以与 Kafka 集群同时部署 Topic Operator 和 User Operator 作为 Entity Operator 配置的一部分。
AMQ Streams 架构中的 Operator
4.1. Cluster Operator
AMQ Streams 使用 Cluster Operator 来部署和管理集群：
- Kafka（包括 ZooKeeper、实体 Operator、Kafka Exporter 和 Cruise Control）
- Kafka Connect
- Kafka MirrorMaker
- Kafka Bridge
自定义资源用于部署集群。
例如，部署 Kafka 集群：
-
在 OpenShift 集群中创建了带有集群配置的
Kafka资源。 -
Cluster Operator 根据
Kafka资源中声明的内容部署对应的 Kafka 集群。
Cluster Operator 也可以部署（通过配置 Kafka 资源）：
-
一个主题 Operator，通过
KafkaTopic自定义资源提供 operator 风格的主题管理 -
一个 User Operator，用来通过
KafkaUser自定义资源提供 operator 风格的用户管理
部署的 Entity Operator 中的 Topic Operator 和 User Operator 功能。
Cluster Operator 的架构示例
