1.4.2. 主题 Operator
Topic Operator 提供了通过 OpenShift 资源管理 Kafka 集群中主题的方法。
Topic Operator 的架构示例
Topic Operator 的角色是保留一组 KafkaTopic
OpenShift 资源,描述与对应的 Kafka 主题同步中的 Kafka 主题。
特别是,如果 KafkaTopic
是:
- 创建,主题 Operator 会创建该主题
- 删除的,主题 Operator 会删除该主题
- 更改,主题 Operator 更新该主题
在另一个方向上工作,如果一个主题是:
-
在 Kafka 集群中创建,Operator 会创建一个
KafkaTopic
-
从 Kafka 集群中删除,Operator 会删除
KafkaTopic
-
在 Kafka 集群中更改,Operator 会更新
KafkaTopic
这可让您声明 KafkaTopic
作为应用程序部署的一部分,Topic Operator 将为您创建该主题。您的应用程序只需要处理从所需主题中产生或使用的内容。
如果该主题被重新配置或重新分配给不同的 Kafka 节点,KafkaTopic
将始终保持最新状态。