1.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
1.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
资源):
-
通过
KafkaTopic
自定义资源提供 operator 风格主题管理的主题 Operator -
一个 User Operator,通过
KafkaUser
自定义资源提供 operator 风格的用户管理
部署的 Entity Operator 中的 Topic Operator 和 User Operator 功能。
Cluster Operator 的架构示例