[ https://issues.apache.org/jira/browse/KAFKA-16118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
David Jacot resolved KAFKA-16118. --------------------------------- Fix Version/s: 3.8.0 Resolution: Fixed > Coordinator unloading fails when replica is deleted > --------------------------------------------------- > > Key: KAFKA-16118 > URL: https://issues.apache.org/jira/browse/KAFKA-16118 > Project: Kafka > Issue Type: Sub-task > Reporter: David Jacot > Assignee: David Jacot > Priority: Major > Fix For: 3.8.0 > > > The new group coordinator always expects the leader epoch to be received when > it must unload the metadata for a partition. However, in KRaft, the leader > epoch is not passed when the replica is delete (e.g. after reassignment). > {noformat} > java.lang.IllegalArgumentException: The leader epoch should always be > provided in KRaft. > at > org.apache.kafka.coordinator.group.GroupCoordinatorService.onResignation(GroupCoordinatorService.java:931) > at > kafka.server.metadata.BrokerMetadataPublisher.$anonfun$onMetadataUpdate$9(BrokerMetadataPublisher.scala:200) > at > kafka.server.metadata.BrokerMetadataPublisher.$anonfun$onMetadataUpdate$9$adapted(BrokerMetadataPublisher.scala:200) > at > kafka.server.metadata.BrokerMetadataPublisher.$anonfun$updateCoordinator$4(BrokerMetadataPublisher.scala:397) > at java.base/java.lang.Iterable.forEach(Iterable.java:75) > at > kafka.server.metadata.BrokerMetadataPublisher.updateCoordinator(BrokerMetadataPublisher.scala:396) > at > kafka.server.metadata.BrokerMetadataPublisher.$anonfun$onMetadataUpdate$7(BrokerMetadataPublisher.scala:200) > at > kafka.server.metadata.BrokerMetadataPublisher.onMetadataUpdate(BrokerMetadataPublisher.scala:186) > at > org.apache.kafka.image.loader.MetadataLoader.maybePublishMetadata(MetadataLoader.java:382) > at > org.apache.kafka.image.loader.MetadataBatchLoader.applyDeltaAndUpdate(MetadataBatchLoader.java:286) > at > org.apache.kafka.image.loader.MetadataBatchLoader.maybeFlushBatches(MetadataBatchLoader.java:222) > at > org.apache.kafka.image.loader.MetadataLoader.lambda$handleCommit$1(MetadataLoader.java:406) > at > org.apache.kafka.queue.KafkaEventQueue$EventContext.run(KafkaEventQueue.java:127) > at > org.apache.kafka.queue.KafkaEventQueue$EventHandler.handleEvents(KafkaEventQueue.java:210) > at > org.apache.kafka.queue.KafkaEventQueue$EventHandler.run(KafkaEventQueue.java:181) > at java.base/java.lang.Thread.run(Thread.java:1583) > at > org.apache.kafka.common.utils.KafkaThread.run(KafkaThread.java:66){noformat} > The side effect of this bug is that group coordinator loading/unloading fails. -- This message was sent by Atlassian Jira (v8.20.10#820010)