Kafka0.8.2.1删除topic逻辑

前提条件： 在启动broker时候开启删除topic的开关，即在server.properties中添加：  delete.topic.enable=true

命令： bin/kafka-topics.sh --zookeeper zk_host:port/chroot --delete --topic my_topic_name

这条命令其实就是在zookeeper（假设你的chroot就是/）的/admin/delete_topics下建立一个临时节点，名字就是topic名称，好比若是执行命令：

bin/kafka-topics.sh --zookeeper zk_host:port/chroot --delete --topic test-topic

那么，命令返回后，zookeeper的/admin/delete_topics目录下会新建立一个临时节点test-topic

 

这条命令返回打印在控制台上的消息也说明了这点：

Topic test-topic is marked for deletion.

Note: This will have no impact if delete.topic.enable is not set to true.

这就是说，这条命令其实并不执行删除动做，仅仅是在zookeeper上标记该topic要被删除而已，同时也提醒用户必定要提早打开delete.topic.enable开关，不然删除动做是不会执行的。

 

那么，咱们经过命令标记了test-topic要被删除以后Kafka是怎么执行删除操做的呢？ 总的流程以下图所示：

1. Kafka controller在启动的时候会注册对于Zookeeper节点/admin/delete_topics的子节点变动监听器——上面的分析已经告诉咱们，delete命令实际上就是要在该节点下建立一个临时节点，名字是待删除topic名，标记该topic是待删除的

2. Kafka controller在启动时建立一个单独的线程，执行topic删除的操做 (由DeleteTopicsThread类实现)

3. 线程启动时查看是否有须要进行删除的topic——假设咱们是在controller启动以后执行的topic删除命令，那么该线程刚启动的时候待删除的topic集合应该就是空的

4. 一旦发现待删除topic集合是空，topic删除线程会被挂起

5. 这时，咱们执行delete操做，删除topic： test-topic，delete命令在/admin/delete_topics下建立子节点test-topic

6. 监听器捕获到该变动，马上触发删除逻辑

    6.1 查询test-topic是否存在，不存在的话直接删除/admin/delete_topics/test-topic节点——随便删除一个不存在的topic，删除命令也只是建立/admin/delete_topics/[topicName]的节点，它不负责作存在性校验

    6.2 查询一下test-topic是否是当前正在执行Preferred副本选举或分区重分配，若是是的话，确定是不适合进行删除掉的。Controller本地会缓存当前没法进行删除的topic集合，待分区重分配完成或preferred副本选举后单独处理该集合中的topic

    6.3 如何二者都不是的话说明如今能够进行删除操做，那么就恢复挂起的删除线程执行删除操做

 

删除线程执行删除操做的真正逻辑是：

1. 它首先会给当前全部broker发送更新元数据信息的请求，告诉这些broker说这个topic要删除了，大家能够把它的信息从缓存中删掉了

2. 开始删除这个topic的全部分区

    2.1 给全部broker发请求，告诉它们这些分区要被删除。broker收到后就再也不接受任何在这些分区上的客户端请求了

    2.2 把每一个分区下的全部副本都置于OfflineReplica状态，这样ISR就不断缩小，当leader副本最后也被置于OfflineReplica状态时leader信息将被更新为-1

    2.3 将全部副本置于ReplicaDeletionStarted状态

    2.4 副本状态机捕获状态变动，而后发起StopReplicaRequest给broker，broker接到请求后中止全部fetcher线程、移除缓存，而后删除底层log文件

    2.5 关闭全部空闲的Fetcher线程

3. 删除zookeeper下/brokers/topics/test-topic节点

4. 删除zookeeper下/config/topics/test-topic节点

5. 删除zookeeper下/admin/delete_topics/test-topic节点

6. 更新各类缓存，把test-topic相关信息移除出去