删除Kafka测试主题后Broker磁盘及主题状态异常原因咨询

现象1：仅单个Broker磁盘使用率下降的原因 #

• 你执行删除主题操作时，Kafka集群的控制器Broker会率先启动删除流程：它先清理主题对应的元数据（比如存储在ZooKeeper或Kafka自身元数据存储中的主题信息），同时删除本地存储的该主题所有分区副本数据，所以这个Broker的磁盘使用率会立刻下降。
• 另外两个Broker的删除操作是异步触发的：控制器需要向它们发送删除指令，待Broker收到指令后，才会启动后台线程删除本地的分区副本文件。如果这两个Broker和控制器存在通信延迟、或者副本处于非同步状态，删除操作就会滞后，磁盘使用率暂时没有变化。
• 还有一种可能是这两个Broker的后台删除线程处于排队状态，Kafka不会立即强制删除磁盘文件，而是会在系统资源空闲的时机执行清理。

现象2：主题显示"Marked for deletion"的原因 #

• 开启delete.topic.enable=true后，Kafka的主题删除是异步流程：执行删除命令后，系统只会先把主题标记为"待删除"状态，不会立刻从集群中移除。
• 只有当控制器确认所有Broker都完成了该主题分区副本的磁盘文件删除，并且同步了元数据后，才会彻底清除这个主题的标记。如果删除流程中出现异常（比如某个Broker离线、副本状态异常导致删除指令无法执行），这个标记就会一直保留。

内容的提问来源于stack exchange，提问作者Dushan