Hi all, I find KAFKA-1641, it's fixed. But I encounter this bug in kafka-0.10.0.0. Log as follow: [2016-12-02 11:33:52,744] ERROR [kafka-log-cleaner-thread-0], Error due to (kafka.log.LogCleaner) java.lang.IllegalArgumentException: requirement failed: Last clean offset is 282330655505 but segment base offset is 0 for log __consumer_offsets-11. at scala.Predef$.require(Predef.scala:224) at kafka.log.Cleaner.buildOffsetMap(LogCleaner.scala:617) at kafka.log.Cleaner.clean(LogCleaner.scala:329) at kafka.log.LogCleaner$CleanerThread.cleanOrSleep(LogCleaner.scala:237) at kafka.log.LogCleaner$CleanerThread.doWork(LogCleaner.scala:215) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) [2016-12-02 11:33:52,744] INFO [kafka-log-cleaner-thread-0], Stopped (kafka.log.LogCleaner)
Thanks. Yuanjia Li