KafkaController是Kafka中的重要角色，主要职责包括：

• 主题管理：负责创建、删除、修改主题。

• 分区管理：负责创建、删除、移动分区。

• 副本管理：负责副本的同步、迁移、选举等。

• 集群状态管理：负责监控集群状态，处理集群故障。

KafkaController源码结构

KafkaController类结构如下图所示：

KafkaController初始化过程

KafkaController选主

KafkaController事件管理