1.2.2. 主题 Operator

Topic Operator 提供了通过 OpenShift 资源管理 Kafka 集群中主题的方法。

Topic Operator 的架构示例

The Topic Operator manages topics for a Kafka cluster via KafkaTopic resources

Topic Operator 的角色是保留一组 KafkaTopic OpenShift 资源，描述与对应的 Kafka 主题同步中的 Kafka 主题。

特别是，如果 KafkaTopic 是：

  • 创建，主题 Operator 会创建该主题
  • 删除的，主题 Operator 会删除该主题
  • 更改，主题 Operator 更新该主题

在另一个方向上工作，如果一个主题是：

  • 在 Kafka 集群中创建，Operator 会创建一个 KafkaTopic
  • 从 Kafka 集群中删除，Operator 会删除 KafkaTopic
  • 在 Kafka 集群中更改，Operator 会更新 KafkaTopic

这可让您声明 KafkaTopic 作为应用程序部署的一部分，Topic Operator 将为您创建该主题。您的应用程序只需要处理从所需主题中产生或使用的内容。

Topic Operator 在主题 存储中维护每个主题 的信息，它与来自 Kafka 主题或 OpenShift KafkaTopic 自定义资源的更新持续同步。应用到本地内存中主题存储的操作的更新会保留在磁盘上的备份主题存储中。如果某个主题被重新配置或重新分配给其他代理，KafkaTopic 将始终保持最新状态。