[jira] [Commented] (KAFKA-9412) LogCleaner stopped for NoSuchElementException

["Ismael Juma (Jira)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/KAFKA-9412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17014365#comment-17014365 ] 

Ismael Juma commented on KAFKA-9412:
------------------------------------

Thanks for the report. 0.11.0.3 is very old. Would you be able to upgrade to a newer version?

> 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)