wangzzu / awesome

不积硅步,无以至千里
228 stars 47 forks source link

Kafka 目录检测 #14

Closed wangzzu closed 5 years ago

wangzzu commented 7 years ago

这样一个场景:如果 kafka 的一台 broker 宕机了,对其数据迁移完成后,现在该机器修复了,需要重新加入到 Kafka Cluster 中,但其目录下还有一些旧的 partition 目录,而 Kafka 不会自动删除这些并不使用的目录。