Here is the implementation for the KIP 370. https://github.com/xiowu0/kafka/commit/f1bd3085639f41a7af02567550a8e3018cfac3e9
The purpose is to do one time cleanup (after a configured delay) of orphan partitions when a broker starts up. Xiongqi (Wesley) Wu On Wed, Sep 5, 2018 at 10:51 AM xiongqi wu <xiongq...@gmail.com> wrote: > > This KIP enables broker to remove orphan partitions automatically. > > > https://cwiki.apache.org/confluence/display/KAFKA/KIP-370%3A+Remove+Orphan+Partitions > > > Xiongqi (Wesley) Wu >
