2019-07-26 14:12:27.469 [kafka-log-cleaner-thread-4] [ERROR] kafka.log.LogCleaner - [kafka-log-cleaner-thread-4]: Error due to java.lang.IllegalStateException: currentLog cannot be empty on an unexpected exception at kafka.log.LogCleaner$CleanerThread.cleanFilthiestLog(LogCleaner.scala:346) at kafka.log.LogCleaner$CleanerThread.doWork(LogCleaner.scala:307) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:89) Caused by: java.lang.IllegalArgumentException: inconsistent range at java.util.concurrent.ConcurrentSkipListMap$SubMap.(ConcurrentSkipListMap.java:2603) at java.util.concurrent.ConcurrentSkipListMap.subMap(ConcurrentSkipListMap.java:2061) at java.util.concurrent.ConcurrentSkipListMap.subMap(ConcurrentSkipListMap.java:2097) at kafka.log.Log.$anonfun$logSegments$1(Log.scala:1920) at scala.Option.map(Option.scala:163) at kafka.log.Log.logSegments(Log.scala:1919) at kafka.log.LogCleanerManager$.getMaxCompactionDelay(LogCleanerManager.scala:492) at kafka.log.LogCleanerManager.$anonfun$grabFilthiestCompactedLog$4(LogCleanerManager.scala:184) at scala.collection.TraversableLike.$anonfun$map$1(TraversableLike.scala:237) at scala.collection.immutable.List.foreach(List.scala:392) at scala.collection.TraversableLike.map(TraversableLike.scala:237) at scala.collection.TraversableLike.map$(TraversableLike.scala:230) at scala.collection.immutable.List.map(List.scala:298) at kafka.log.LogCleanerManager.$anonfun$grabFilthiestCompactedLog$1(LogCleanerManager.scala:179) at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:253) at kafka.log.LogCleanerManager.grabFilthiestCompactedLog(LogCleanerManager.scala:169) at kafka.log.LogCleaner$CleanerThread.cleanFilthiestLog(LogCleaner.scala:321) ... 2 more 2019-07-26 14:12:27.470 [kafka-log-cleaner-thread-4] [INFO ] kafka.log.LogCleaner - [kafka-log-cleaner-thread-4]: Stopped