概述
Kafka 是一种高吞吐量的分布式发布订阅消息系统。部署 Kafaka Operator 后,可在数据服务视图中使用 Kafka 功能。
Kafka Operator 简介
Strimzi 简化了在 Kubernetes 集群中运行 Apache Kafka 的过程。Strimzi 允许开发者在 Kubernetes 上运行 Apache Kafka 及其生态系统。它提供了用于运行 Apache Kafka 的容器镜像。Strimzi 由 CNCF(Cloud Native Computing Foundation,云原生计算基金会)托管。
Strimzi 使用 Operators 支持 Kafka 来部署和管理 Kafka 到 Kubernetes 的组件和依赖项。Kafka Operator 用于部署、管理和配置 Apache Kafka 集群。Strimzi 体系结构中的 Operator 如下图所示。

Kafka Operator 扩展了 Kubernetes 的功能,自动执行与 Kafka 部署相关的常见和复杂任务。通过在代码中实现对 Kafka 操作的了解,简化了 Kafka 管理任务,并减少了人工干预。
Kafka Operator 核心功能
Kafka 的基础数据流处理功能和组件体系结构可以提供:
-
管理 Kafka 集群:部署和管理此复杂应用程序的所有组件,包括传统上难以管理的依赖项,例如 Apache ZooKeeper ;
-
包括 Kafka Connect:允许配置通用数据源和接收器,以将数据移入和移出 Kafka 集群;
-
Topic 管理:在集群中创建和管理 Kafka Topic;
-
用户管理:在集群中创建和管理 Kafka 用户;
-
连接器管理:创建和管理 Kafka Connect 连接器;
-
包括 Kafka Mirror Maker 1 和 2 :允许在不同的 Apache Kafka 集群之间存储数据;
-
包括 HTTP Kafka Bridge :允许客户端通过 HTTP 协议通过 Apache Kafka 集群发送和接收消息;
-
集群重新平衡:使用内置的 Cruise Control,可以根据指定的目标重新分配分区副本,以实现最佳的集群性能;
-
监控:使用 Prometheus 和其提供的 Grafana dashabords 进行监控的内置支持。
如需了解 Kafka 架构的详细信息,请
前往 Strimzi 官网
,或 [下载官方文档至本地](/zh/img/ds/Kafka Deployment configuration.doc) (右键单击该链接,选择 链接存储为…
)。