[ https://issues.apache.org/jira/browse/KAFKA-16180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Ismael Juma updated KAFKA-16180: -------------------------------- Description: Example: {code:java} java.util.NoSuchElementException: topic_name at scala.collection.mutable.AnyRefMap$ExceptionDefault.apply(AnyRefMap.scala:508) at scala.collection.mutable.AnyRefMap$ExceptionDefault.apply(AnyRefMap.scala:507) at scala.collection.mutable.AnyRefMap.apply(AnyRefMap.scala:207) at kafka.server.metadata.ZkMetadataCache$.$anonfun$maybeInjectDeletedPartitionsFromFullMetadataRequest$2(ZkMetadataCache.scala:112) at kafka.server.metadata.ZkMetadataCache$.$anonfun$maybeInjectDeletedPartitionsFromFullMetadataRequest$2$adapted(ZkMetadataCache.scala:105) at scala.collection.immutable.HashSet.foreach(HashSet.scala:958) at kafka.server.metadata.ZkMetadataCache$.maybeInjectDeletedPartitionsFromFullMetadataRequest(ZkMetadataCache.scala:105) at kafka.server.metadata.ZkMetadataCache.$anonfun$updateMetadata$1(ZkMetadataCache.scala:506) at kafka.utils.CoreUtils$.inWriteLock(CoreUtils.scala:183) at kafka.server.metadata.ZkMetadataCache.updateMetadata(ZkMetadataCache.scala:496) at kafka.server.ReplicaManager.maybeUpdateMetadataCache(ReplicaManager.scala:2482) at kafka.server.KafkaApis.handleUpdateMetadataRequest(KafkaApis.scala:733) at kafka.server.KafkaApis.handle(KafkaApis.scala:349) at kafka.server.KafkaRequestHandler.$anonfun$poll$8(KafkaRequestHandler.scala:210) at kafka.server.KafkaRequestHandler.$anonfun$poll$8$adapted(KafkaRequestHandler.scala:210) at io.confluent.kafka.availability.ThreadCountersManager.wrapEngine(ThreadCountersManager.java:146) at kafka.server.KafkaRequestHandler.poll(KafkaRequestHandler.scala:210) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:151) at java.base/java.lang.Thread.run(Thread.java:1583) at org.apache.kafka.common.utils.KafkaThread.run(KafkaThread.java:66) {code} was: Example: {code} java.util.NoSuchElementException: dev_kafka.stream.detection.bucket3-KTABLE-SUPPRESS-STATE-STORE-0000000008-changelog at scala.collection.mutable.AnyRefMap$ExceptionDefault.apply(AnyRefMap.scala:508) at scala.collection.mutable.AnyRefMap$ExceptionDefault.apply(AnyRefMap.scala:507) at scala.collection.mutable.AnyRefMap.apply(AnyRefMap.scala:207) at kafka.server.metadata.ZkMetadataCache$.$anonfun$maybeInjectDeletedPartitionsFromFullMetadataRequest$2(ZkMetadataCache.scala:112) at kafka.server.metadata.ZkMetadataCache$.$anonfun$maybeInjectDeletedPartitionsFromFullMetadataRequest$2$adapted(ZkMetadataCache.scala:105) at scala.collection.immutable.HashSet.foreach(HashSet.scala:958) at kafka.server.metadata.ZkMetadataCache$.maybeInjectDeletedPartitionsFromFullMetadataRequest(ZkMetadataCache.scala:105) at kafka.server.metadata.ZkMetadataCache.$anonfun$updateMetadata$1(ZkMetadataCache.scala:506) at kafka.utils.CoreUtils$.inWriteLock(CoreUtils.scala:183) at kafka.server.metadata.ZkMetadataCache.updateMetadata(ZkMetadataCache.scala:496) at kafka.server.ReplicaManager.maybeUpdateMetadataCache(ReplicaManager.scala:2482) at kafka.server.KafkaApis.handleUpdateMetadataRequest(KafkaApis.scala:733) at kafka.server.KafkaApis.handle(KafkaApis.scala:349) at kafka.server.KafkaRequestHandler.$anonfun$poll$8(KafkaRequestHandler.scala:210) at kafka.server.KafkaRequestHandler.$anonfun$poll$8$adapted(KafkaRequestHandler.scala:210) at io.confluent.kafka.availability.ThreadCountersManager.wrapEngine(ThreadCountersManager.java:146) at kafka.server.KafkaRequestHandler.poll(KafkaRequestHandler.scala:210) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:151) at java.base/java.lang.Thread.run(Thread.java:1583) at org.apache.kafka.common.utils.KafkaThread.run(KafkaThread.java:66) {code} > Full metadata request sometimes fails during zk migration > --------------------------------------------------------- > > Key: KAFKA-16180 > URL: https://issues.apache.org/jira/browse/KAFKA-16180 > Project: Kafka > Issue Type: Bug > Affects Versions: 3.7.0 > Reporter: Colin McCabe > Priority: Blocker > > Example: > {code:java} > java.util.NoSuchElementException: topic_name > at > scala.collection.mutable.AnyRefMap$ExceptionDefault.apply(AnyRefMap.scala:508) > at > scala.collection.mutable.AnyRefMap$ExceptionDefault.apply(AnyRefMap.scala:507) > at scala.collection.mutable.AnyRefMap.apply(AnyRefMap.scala:207) > at > kafka.server.metadata.ZkMetadataCache$.$anonfun$maybeInjectDeletedPartitionsFromFullMetadataRequest$2(ZkMetadataCache.scala:112) > at > kafka.server.metadata.ZkMetadataCache$.$anonfun$maybeInjectDeletedPartitionsFromFullMetadataRequest$2$adapted(ZkMetadataCache.scala:105) > at scala.collection.immutable.HashSet.foreach(HashSet.scala:958) > at > kafka.server.metadata.ZkMetadataCache$.maybeInjectDeletedPartitionsFromFullMetadataRequest(ZkMetadataCache.scala:105) > at > kafka.server.metadata.ZkMetadataCache.$anonfun$updateMetadata$1(ZkMetadataCache.scala:506) > at kafka.utils.CoreUtils$.inWriteLock(CoreUtils.scala:183) > at > kafka.server.metadata.ZkMetadataCache.updateMetadata(ZkMetadataCache.scala:496) > at > kafka.server.ReplicaManager.maybeUpdateMetadataCache(ReplicaManager.scala:2482) > at > kafka.server.KafkaApis.handleUpdateMetadataRequest(KafkaApis.scala:733) > at kafka.server.KafkaApis.handle(KafkaApis.scala:349) > at > kafka.server.KafkaRequestHandler.$anonfun$poll$8(KafkaRequestHandler.scala:210) > at > kafka.server.KafkaRequestHandler.$anonfun$poll$8$adapted(KafkaRequestHandler.scala:210) > at > io.confluent.kafka.availability.ThreadCountersManager.wrapEngine(ThreadCountersManager.java:146) > at > kafka.server.KafkaRequestHandler.poll(KafkaRequestHandler.scala:210) > at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:151) > at java.base/java.lang.Thread.run(Thread.java:1583) > at org.apache.kafka.common.utils.KafkaThread.run(KafkaThread.java:66) > {code} -- This message was sent by Atlassian Jira (v8.20.10#820010)