[ https://issues.apache.org/jira/browse/KAFKA-9412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17014816#comment-17014816 ]
evan einst commented on KAFKA-9412: ----------------------------------- We plan to upgrade next month > LogCleaner stopped for NoSuchElementException > --------------------------------------------- > > Key: KAFKA-9412 > URL: https://issues.apache.org/jira/browse/KAFKA-9412 > Project: Kafka > Issue Type: Bug > Components: core > Affects Versions: 0.11.0.3 > Reporter: evan einst > Priority: Major > > log cleaner stopped for NoSuchElementException when it calls > CleanedTransactionMetadata.onControlBatchRead. It should be the same problem > with https://issues.apache.org/jira/browse/KAFKA-7467 > {code:java} > [2019-12-31 20:35:57,527] INFO Cleaner 0: Cleaning segment 321799403 in log > __consumer_offsets-30 (largest timestamp Wed Dec 04 13:48:46 CST 2019) into > 321799403, discarding deletes. (kafka.log.LogCleaner) > [2019-12-31 20:35:57,600] ERROR [kafka-log-cleaner-thread-0]: Error due to > (kafka.log.LogCleaner) > java.util.NoSuchElementException > at java.util.Collections$EmptyIterator.next(Collections.java:4191) > at > kafka.log.CleanedTransactionMetadata.onControlBatchRead(LogCleaner.scala:876) > at > kafka.log.Cleaner.kafka$log$Cleaner$$shouldDiscardBatch(LogCleaner.scala:566) > at kafka.log.Cleaner$$anon$5.checkBatchRetention(LogCleaner.scala:505) > at > org.apache.kafka.common.record.MemoryRecords.filterTo(MemoryRecords.java:155) > at > org.apache.kafka.common.record.MemoryRecords.filterTo(MemoryRecords.java:136) > at kafka.log.Cleaner.cleanInto(LogCleaner.scala:536) > at kafka.log.Cleaner.cleanSegments(LogCleaner.scala:444) > at kafka.log.Cleaner.$anonfun$doClean$6(LogCleaner.scala:385) > at kafka.log.Cleaner.$anonfun$doClean$6$adapted(LogCleaner.scala:384) > at scala.collection.immutable.List.foreach(List.scala:389) > at kafka.log.Cleaner.doClean(LogCleaner.scala:384) > at kafka.log.Cleaner.clean(LogCleaner.scala:361) > at kafka.log.LogCleaner$CleanerThread.cleanOrSleep(LogCleaner.scala:256) > at kafka.log.LogCleaner$CleanerThread.doWork(LogCleaner.scala:236) > at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:64) > [2019-12-31 20:35:57,600] INFO [kafka-log-cleaner-thread-0]: Stopped > (kafka.log.LogCleaner){code} > -- This message was sent by Atlassian Jira (v8.3.4#803005)