[KAFKA-12763] NoSuchElementException during kafka-log-start-offset-checkpoint

• Type: Bug
• Status: Open
• Priority: Minor
• Resolution: Unresolved
• Affects Version/s: 2.6.2
• Component/s: log
• Assignee: Igor Soarez
• Reporter: Igor Soarez
• Created: 07/May/21 15:57
• Updated: 20/Oct/22 16:54

Description

The following exception was observed in a cluster running Kafka version 2.6.2.

 

{
  "class": "java.util.NoSuchElementException",
  "msg": null,
  "stack": [
    "java.util.concurrent.ConcurrentSkipListMap$ValueIterator.next(ConcurrentSkipListMap.java:2123)",
    "scala.collection.convert.JavaCollectionWrappers$JIteratorWrapper.next(JavaCollectionWrappers.scala:38)",
    "scala.collection.IterableOps.head(Iterable.scala:218)",
    "scala.collection.IterableOps.head$(Iterable.scala:218)",
    "scala.collection.AbstractIterable.head(Iterable.scala:920)",
    "kafka.log.LogManager$$anonfun$4.applyOrElse(LogManager.scala:640)",
    "kafka.log.LogManager$$anonfun$4.applyOrElse(LogManager.scala:639)",
    "scala.collection.Iterator$$anon$7.hasNext(Iterator.scala:516)",
    "scala.collection.mutable.Growable.addAll(Growable.scala:61)",
    "scala.collection.mutable.Growable.addAll$(Growable.scala:59)",
    "scala.collection.mutable.HashMap.addAll(HashMap.scala:111)",
    "scala.collection.mutable.HashMap$.from(HashMap.scala:549)",
    "scala.collection.mutable.HashMap$.from(HashMap.scala:542)",
    "scala.collection.MapFactory$Delegate.from(Factory.scala:425)",
    "scala.collection.MapOps.collect(Map.scala:283)",
    "scala.collection.MapOps.collect$(Map.scala:282)",
    "scala.collection.AbstractMap.collect(Map.scala:375)",
    "kafka.log.LogManager.$anonfun$checkpointLogStartOffsetsInDir$2(LogManager.scala:639)",
    "kafka.log.LogManager.$anonfun$checkpointLogStartOffsetsInDir$1(LogManager.scala:636)",
    "kafka.log.LogManager.checkpointLogStartOffsetsInDir(LogManager.scala:635)",
    "kafka.log.LogManager.$anonfun$checkpointLogStartOffsets$1(LogManager.scala:600)",
    "kafka.log.LogManager.$anonfun$checkpointLogStartOffsets$1$adapted(LogManager.scala:600)",
    "scala.collection.IterableOnceOps.foreach(IterableOnce.scala:553)",
    "scala.collection.IterableOnceOps.foreach$(IterableOnce.scala:551)",
    "scala.collection.AbstractIterable.foreach(Iterable.scala:920)",
    "kafka.log.LogManager.checkpointLogStartOffsets(LogManager.scala:600)",
    "kafka.log.LogManager.$anonfun$startup$6(LogManager.scala:426)",
    "kafka.utils.KafkaScheduler.$anonfun$schedule$2(KafkaScheduler.scala:114)",
    "java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)",
    "java.util.concurrent.FutureTask.runAndReset(FutureTask.java:305)",
    "java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305)",
    "java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)",
    "java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)",
    "java.lang.Thread.run(Thread.java:834)"
  ]
}

 

Issue Links

• links to: GitHub Pull Request #10650