6.2. Topic Operator
主题 Operator 提供了通过 KafkaTopic
资源管理 Kafka 集群中的主题的方法。
主题 Operator 的架构示例
主题 Operator 通过监视 describe Kafka 主题的 KafkaTopic
资源来管理 Kafka 主题,并确保它们在 Kafka 集群中正确配置。
当创建、删除或更改 KafkaTopic
时,主题 Operator 对 Kafka 主题执行对应的操作。
您可以将 KafkaTopic
声明为应用程序部署的一部分,主题 Operator 会为您管理 Kafka 主题。
主题 Operator 以以下模式运行:
- 双向模式
双向模式意味着 Topic Operator 可以协调对 Kafka 集群的
KafkaTopic
资源的更改。这意味着,您可以通过KafkaTopic
资源或在 Kafka 中直接更新主题,主题 Operator 可确保更新这两个源以反映更改。这个模式需要 ZooKeeper 用于集群管理。主题 Operator 维护有关主题存储中的每个主题的信息,该存储会持续与 OpenShift
KafkaTopic
自定义资源或 Kafka 主题的更新同步。应用到本地内存主题存储的操作更新将保留到磁盘上的备份主题。- 单向模式(预览)
-
单向模式意味着主题 Operator 通过
KafkaTopic
资源单独管理主题。这个模式不需要 ZooKeeper,并在 KRaft 模式下与使用 AMQ Streams 兼容。