m1a2st commented on PR #17014:
URL: https://github.com/apache/kafka/pull/17014#issuecomment-2326922280
The error log is
```text
[Admin Manager on Broker 0]: Error processing create topic request
CreatableTopic(name='__consumer_offsets', numPartitions=5,
replicationFactor=1, assignments=[],
configs=[CreatableTopicConfig(name='compression.type', value='producer'),
CreatableTopicConfig(name='cleanup.policy', value='compact'),
CreatableTopicConfig(name='segment.bytes', value='104857600')])
org.apache.zookeeper.KeeperException$SessionExpiredException:
KeeperErrorCode = Session expired for /admin/delete_topics/__consumer_offsets
at org.apache.zookeeper.KeeperException.create(KeeperException.java:134)
at org.apache.zookeeper.KeeperException.create(KeeperException.java:54)
at
kafka.zookeeper.AsyncResponse.resultException(ZooKeeperClient.scala:555)
at kafka.zk.KafkaZkClient.pathExists(KafkaZkClient.scala:1891)
at
kafka.zk.KafkaZkClient.isTopicMarkedForDeletion(KafkaZkClient.scala:1009)
at kafka.zk.AdminZkClient.validateTopicCreate(AdminZkClient.scala:133)
at
kafka.server.ZkAdminManager.$anonfun$createTopics$1(ZkAdminManager.scala:204)
at scala.collection.Iterator$$anon$9.next(Iterator.scala:584)
at scala.collection.immutable.List.prependedAll(List.scala:153)
at scala.collection.immutable.List$.from(List.scala:685)
at scala.collection.immutable.List$.from(List.scala:682)
at scala.collection.IterableFactory$Delegate.from(Factory.scala:288)
at scala.collection.immutable.Iterable$.from(Iterable.scala:35)
at scala.collection.immutable.Iterable$.from(Iterable.scala:32)
at scala.collection.IterableFactory$Delegate.from(Factory.scala:288)
at scala.collection.IterableOps.map(Iterable.scala:684)
at scala.collection.IterableOps.map$(Iterable.scala:684)
at scala.collection.AbstractIterable.map(Iterable.scala:935)
at kafka.server.ZkAdminManager.createTopics(ZkAdminManager.scala:168)
at
kafka.server.DefaultAutoTopicCreationManager.createTopicsInZk(AutoTopicCreationManager.scala:122)
at
kafka.server.DefaultAutoTopicCreationManager.createTopics(AutoTopicCreationManager.scala:102)
at kafka.server.KafkaApis.getCoordinator(KafkaApis.scala:1699)
at
kafka.server.KafkaApis.$anonfun$handleFindCoordinatorRequestV4AndAbove$1(KafkaApis.scala:1626)
at
scala.collection.StrictOptimizedIterableOps.map(StrictOptimizedIterableOps.scala:100)
at
scala.collection.StrictOptimizedIterableOps.map$(StrictOptimizedIterableOps.scala:87)
at
scala.collection.convert.JavaCollectionWrappers$JListWrapper.map(JavaCollectionWrappers.scala:138)
at
kafka.server.KafkaApis.handleFindCoordinatorRequestV4AndAbove(KafkaApis.scala:1625)
at
kafka.server.KafkaApis.handleFindCoordinatorRequest(KafkaApis.scala:1618)
at kafka.server.KafkaApis.handle(KafkaApis.scala:203)
at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:159)
at java.base/java.lang.Thread.run(Thread.java:833)
22493 [data-plane-kafka-request-handler-6] ERROR state.change.logger -
[Broker id=0] Error while processing LeaderAndIsr request correlationId 13
received from controller 0 epoch 1 for partition __consumer_offsets-3
org.apache.zookeeper.KeeperException$SessionExpiredException:
KeeperErrorCode = Session expired for /config/topics/__consumer_offsets
at org.apache.zookeeper.KeeperException.create(KeeperException.java:134)
at org.apache.zookeeper.KeeperException.create(KeeperException.java:54)
at
kafka.zookeeper.AsyncResponse.resultException(ZooKeeperClient.scala:555)
at kafka.zk.KafkaZkClient.getEntityConfigs(KafkaZkClient.scala:435)
at kafka.zk.AdminZkClient.fetchEntityConfig(AdminZkClient.scala:562)
at
kafka.server.metadata.ZkConfigRepository.config(ZkConfigRepository.scala:49)
at
kafka.server.metadata.ConfigRepository.topicConfig(ConfigRepository.scala:33)
at
kafka.server.metadata.ConfigRepository.topicConfig$(ConfigRepository.scala:32)
at
kafka.server.metadata.ZkConfigRepository.topicConfig(ZkConfigRepository.scala:33)
at
kafka.log.LogManager.$anonfun$fetchTopicConfigOverrides$1(LogManager.scala:590)
at
kafka.log.LogManager.$anonfun$fetchTopicConfigOverrides$1$adapted(LogManager.scala:589)
at scala.collection.immutable.Set$Set1.foreach(Set.scala:177)
at kafka.log.LogManager.fetchTopicConfigOverrides(LogManager.scala:589)
at kafka.log.LogManager.fetchLogConfig(LogManager.scala:616)
at kafka.log.LogManager.$anonfun$getOrCreateLog$1(LogManager.scala:1079)
at scala.Option.getOrElse(Option.scala:201)
at kafka.log.LogManager.getOrCreateLog(LogManager.scala:1037)
at kafka.cluster.Partition.createLog(Partition.scala:492)
at kafka.cluster.Partition.maybeCreate$1(Partition.scala:466)
at kafka.cluster.Partition.createLogIfNotExists(Partition.scala:473)
at
kafka.cluster.Partition.createLogInAssignedDirectoryId(Partition.scala:902)
at kafka.cluster.Partition.$anonfun$makeLeader$1(Partition.scala:759)
at kafka.cluster.Partition.makeLeader(Partition.scala:718)
at
kafka.server.ReplicaManager.$anonfun$makeLeaders$5(ReplicaManager.scala:2210)
at
kafka.utils.Implicits$MapExtensionMethods$.$anonfun$forKeyValue$1(Implicits.scala:62)
at scala.collection.mutable.HashMap$Node.foreachEntry(HashMap.scala:648)
at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:514)
at
kafka.server.ReplicaManager.becomeLeaderOrFollower(ReplicaManager.scala:2208)
at kafka.server.KafkaApis.handleLeaderAndIsrRequest(KafkaApis.scala:313)
at kafka.server.KafkaApis.handle(KafkaApis.scala:197)
at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:159)
at java.base/java.lang.Thread.run(Thread.java:833)
22493 [data-plane-kafka-request-handler-6] ERROR state.change.logger -
[Broker id=0] Error while processing LeaderAndIsr request correlationId 13
received from controller 0 epoch 1 for partition __consumer_offsets-2
org.apache.zookeeper.KeeperException$SessionExpiredException:
KeeperErrorCode = Session expired for /config/topics/__consumer_offsets
at org.apache.zookeeper.KeeperException.create(KeeperException.java:134)
at org.apache.zookeeper.KeeperException.create(KeeperException.java:54)
at
kafka.zookeeper.AsyncResponse.resultException(ZooKeeperClient.scala:555)
at kafka.zk.KafkaZkClient.getEntityConfigs(KafkaZkClient.scala:435)
at kafka.zk.AdminZkClient.fetchEntityConfig(AdminZkClient.scala:562)
at
kafka.server.metadata.ZkConfigRepository.config(ZkConfigRepository.scala:49)
at
kafka.server.metadata.ConfigRepository.topicConfig(ConfigRepository.scala:33)
at
kafka.server.metadata.ConfigRepository.topicConfig$(ConfigRepository.scala:32)
at
kafka.server.metadata.ZkConfigRepository.topicConfig(ZkConfigRepository.scala:33)
at
kafka.log.LogManager.$anonfun$fetchTopicConfigOverrides$1(LogManager.scala:590)
at
kafka.log.LogManager.$anonfun$fetchTopicConfigOverrides$1$adapted(LogManager.scala:589)
at scala.collection.immutable.Set$Set1.foreach(Set.scala:177)
at kafka.log.LogManager.fetchTopicConfigOverrides(LogManager.scala:589)
at kafka.log.LogManager.fetchLogConfig(LogManager.scala:616)
at kafka.log.LogManager.$anonfun$getOrCreateLog$1(LogManager.scala:1079)
at scala.Option.getOrElse(Option.scala:201)
at kafka.log.LogManager.getOrCreateLog(LogManager.scala:1037)
at kafka.cluster.Partition.createLog(Partition.scala:492)
at kafka.cluster.Partition.maybeCreate$1(Partition.scala:466)
at kafka.cluster.Partition.createLogIfNotExists(Partition.scala:473)
at
kafka.cluster.Partition.createLogInAssignedDirectoryId(Partition.scala:902)
at kafka.cluster.Partition.$anonfun$makeLeader$1(Partition.scala:759)
at kafka.cluster.Partition.makeLeader(Partition.scala:718)
at
kafka.server.ReplicaManager.$anonfun$makeLeaders$5(ReplicaManager.scala:2210)
at
kafka.utils.Implicits$MapExtensionMethods$.$anonfun$forKeyValue$1(Implicits.scala:62)
at scala.collection.mutable.HashMap$Node.foreachEntry(HashMap.scala:648)
at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:514)
at
kafka.server.ReplicaManager.becomeLeaderOrFollower(ReplicaManager.scala:2208)
at kafka.server.KafkaApis.handleLeaderAndIsrRequest(KafkaApis.scala:313)
at kafka.server.KafkaApis.handle(KafkaApis.scala:197)
at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:159)
at java.base/java.lang.Thread.run(Thread.java:833)
22493 [data-plane-kafka-request-handler-6] ERROR state.change.logger -
[Broker id=0] Error while processing LeaderAndIsr request correlationId 13
received from controller 0 epoch 1 for partition __consumer_offsets-4
org.apache.zookeeper.KeeperException$SessionExpiredException:
KeeperErrorCode = Session expired for /config/topics/__consumer_offsets
at org.apache.zookeeper.KeeperException.create(KeeperException.java:134)
at org.apache.zookeeper.KeeperException.create(KeeperException.java:54)
at
kafka.zookeeper.AsyncResponse.resultException(ZooKeeperClient.scala:555)
at kafka.zk.KafkaZkClient.getEntityConfigs(KafkaZkClient.scala:435)
at kafka.zk.AdminZkClient.fetchEntityConfig(AdminZkClient.scala:562)
at
kafka.server.metadata.ZkConfigRepository.config(ZkConfigRepository.scala:49)
at
kafka.server.metadata.ConfigRepository.topicConfig(ConfigRepository.scala:33)
at
kafka.server.metadata.ConfigRepository.topicConfig$(ConfigRepository.scala:32)
at
kafka.server.metadata.ZkConfigRepository.topicConfig(ZkConfigRepository.scala:33)
at
kafka.log.LogManager.$anonfun$fetchTopicConfigOverrides$1(LogManager.scala:590)
at
kafka.log.LogManager.$anonfun$fetchTopicConfigOverrides$1$adapted(LogManager.scala:589)
at scala.collection.immutable.Set$Set1.foreach(Set.scala:177)
at kafka.log.LogManager.fetchTopicConfigOverrides(LogManager.scala:589)
at kafka.log.LogManager.fetchLogConfig(LogManager.scala:616)
at kafka.log.LogManager.$anonfun$getOrCreateLog$1(LogManager.scala:1079)
at scala.Option.getOrElse(Option.scala:201)
at kafka.log.LogManager.getOrCreateLog(LogManager.scala:1037)
at kafka.cluster.Partition.createLog(Partition.scala:492)
at kafka.cluster.Partition.maybeCreate$1(Partition.scala:466)
at kafka.cluster.Partition.createLogIfNotExists(Partition.scala:473)
at
kafka.cluster.Partition.createLogInAssignedDirectoryId(Partition.scala:902)
at kafka.cluster.Partition.$anonfun$makeLeader$1(Partition.scala:759)
at kafka.cluster.Partition.makeLeader(Partition.scala:718)
at
kafka.server.ReplicaManager.$anonfun$makeLeaders$5(ReplicaManager.scala:2210)
at
kafka.utils.Implicits$MapExtensionMethods$.$anonfun$forKeyValue$1(Implicits.scala:62)
at scala.collection.mutable.HashMap$Node.foreachEntry(HashMap.scala:648)
at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:514)
at
kafka.server.ReplicaManager.becomeLeaderOrFollower(ReplicaManager.scala:2208)
at kafka.server.KafkaApis.handleLeaderAndIsrRequest(KafkaApis.scala:313)
at kafka.server.KafkaApis.handle(KafkaApis.scala:197)
at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:159)
at java.base/java.lang.Thread.run(Thread.java:833)
22493 [data-plane-kafka-request-handler-6] ERROR state.change.logger -
[Broker id=0] Error while processing LeaderAndIsr request correlationId 13
received from controller 0 epoch 1 for partition __consumer_offsets-1
org.apache.zookeeper.KeeperException$SessionExpiredException:
KeeperErrorCode = Session expired for /config/topics/__consumer_offsets
at org.apache.zookeeper.KeeperException.create(KeeperException.java:134)
at org.apache.zookeeper.KeeperException.create(KeeperException.java:54)
at
kafka.zookeeper.AsyncResponse.resultException(ZooKeeperClient.scala:555)
at kafka.zk.KafkaZkClient.getEntityConfigs(KafkaZkClient.scala:435)
at kafka.zk.AdminZkClient.fetchEntityConfig(AdminZkClient.scala:562)
at
kafka.server.metadata.ZkConfigRepository.config(ZkConfigRepository.scala:49)
at
kafka.server.metadata.ConfigRepository.topicConfig(ConfigRepository.scala:33)
at
kafka.server.metadata.ConfigRepository.topicConfig$(ConfigRepository.scala:32)
at
kafka.server.metadata.ZkConfigRepository.topicConfig(ZkConfigRepository.scala:33)
at
kafka.log.LogManager.$anonfun$fetchTopicConfigOverrides$1(LogManager.scala:590)
at
kafka.log.LogManager.$anonfun$fetchTopicConfigOverrides$1$adapted(LogManager.scala:589)
at scala.collection.immutable.Set$Set1.foreach(Set.scala:177)
at kafka.log.LogManager.fetchTopicConfigOverrides(LogManager.scala:589)
at kafka.log.LogManager.fetchLogConfig(LogManager.scala:616)
at kafka.log.LogManager.$anonfun$getOrCreateLog$1(LogManager.scala:1079)
at scala.Option.getOrElse(Option.scala:201)
at kafka.log.LogManager.getOrCreateLog(LogManager.scala:1037)
at kafka.cluster.Partition.createLog(Partition.scala:492)
at kafka.cluster.Partition.maybeCreate$1(Partition.scala:466)
at kafka.cluster.Partition.createLogIfNotExists(Partition.scala:473)
at
kafka.cluster.Partition.createLogInAssignedDirectoryId(Partition.scala:902)
at kafka.cluster.Partition.$anonfun$makeLeader$1(Partition.scala:759)
at kafka.cluster.Partition.makeLeader(Partition.scala:718)
at
kafka.server.ReplicaManager.$anonfun$makeLeaders$5(ReplicaManager.scala:2210)
at
kafka.utils.Implicits$MapExtensionMethods$.$anonfun$forKeyValue$1(Implicits.scala:62)
at scala.collection.mutable.HashMap$Node.foreachEntry(HashMap.scala:648)
at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:514)
at
kafka.server.ReplicaManager.becomeLeaderOrFollower(ReplicaManager.scala:2208)
at kafka.server.KafkaApis.handleLeaderAndIsrRequest(KafkaApis.scala:313)
at kafka.server.KafkaApis.handle(KafkaApis.scala:197)
at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:159)
at java.base/java.lang.Thread.run(Thread.java:833)
22494 [data-plane-kafka-request-handler-6] ERROR state.change.logger -
[Broker id=0] Error while processing LeaderAndIsr request correlationId 13
received from controller 0 epoch 1 for partition __consumer_offsets-0
org.apache.zookeeper.KeeperException$SessionExpiredException:
KeeperErrorCode = Session expired for /config/topics/__consumer_offsets
at org.apache.zookeeper.KeeperException.create(KeeperException.java:134)
at org.apache.zookeeper.KeeperException.create(KeeperException.java:54)
at
kafka.zookeeper.AsyncResponse.resultException(ZooKeeperClient.scala:555)
at kafka.zk.KafkaZkClient.getEntityConfigs(KafkaZkClient.scala:435)
at kafka.zk.AdminZkClient.fetchEntityConfig(AdminZkClient.scala:562)
at
kafka.server.metadata.ZkConfigRepository.config(ZkConfigRepository.scala:49)
at
kafka.server.metadata.ConfigRepository.topicConfig(ConfigRepository.scala:33)
at
kafka.server.metadata.ConfigRepository.topicConfig$(ConfigRepository.scala:32)
at
kafka.server.metadata.ZkConfigRepository.topicConfig(ZkConfigRepository.scala:33)
at
kafka.log.LogManager.$anonfun$fetchTopicConfigOverrides$1(LogManager.scala:590)
at
kafka.log.LogManager.$anonfun$fetchTopicConfigOverrides$1$adapted(LogManager.scala:589)
at scala.collection.immutable.Set$Set1.foreach(Set.scala:177)
at kafka.log.LogManager.fetchTopicConfigOverrides(LogManager.scala:589)
at kafka.log.LogManager.fetchLogConfig(LogManager.scala:616)
at kafka.log.LogManager.$anonfun$getOrCreateLog$1(LogManager.scala:1079)
at scala.Option.getOrElse(Option.scala:201)
at kafka.log.LogManager.getOrCreateLog(LogManager.scala:1037)
at kafka.cluster.Partition.createLog(Partition.scala:492)
at kafka.cluster.Partition.maybeCreate$1(Partition.scala:466)
at kafka.cluster.Partition.createLogIfNotExists(Partition.scala:473)
at
kafka.cluster.Partition.createLogInAssignedDirectoryId(Partition.scala:902)
at kafka.cluster.Partition.$anonfun$makeLeader$1(Partition.scala:759)
at kafka.cluster.Partition.makeLeader(Partition.scala:718)
at
kafka.server.ReplicaManager.$anonfun$makeLeaders$5(ReplicaManager.scala:2210)
at
kafka.utils.Implicits$MapExtensionMethods$.$anonfun$forKeyValue$1(Implicits.scala:62)
at scala.collection.mutable.HashMap$Node.foreachEntry(HashMap.scala:648)
at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:514)
at
kafka.server.ReplicaManager.becomeLeaderOrFollower(ReplicaManager.scala:2208)
at kafka.server.KafkaApis.handleLeaderAndIsrRequest(KafkaApis.scala:313)
at kafka.server.KafkaApis.handle(KafkaApis.scala:197)
at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:159)
at java.base/java.lang.Thread.run(Thread.java:833)
22495 [data-plane-kafka-request-handler-6] ERROR kafka.server.KafkaApis -
[KafkaApi-0] Unexpected error handling
request RequestHeader(apiKey=LEADER_AND_ISR, apiVersion=7, clientId=0,
correlationId=13, headerVersion=2) --
LeaderAndIsrRequestData(controllerId=0, isKRaftController=false,
controllerEpoch=1, brokerEpoch=25, type=0,
ungroupedPartitionStates=[],
topicStates=[LeaderAndIsrTopicState(topicName='__consumer_offsets',
topicId=s5rKVYDpR6WtM9oWa2eTZA,
partitionStates=[LeaderAndIsrPartitionState(topicName='__consumer_offsets',
partitionIndex=0, controllerEpoch=1, leader=0,
leaderEpoch=0, isr=[0], partitionEpoch=0, replicas=[0], addingReplicas=[],
removingReplicas=[], isNew=true, leaderRecoveryState=0),
LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=3,
controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
partitionEpoch=0, replicas=[0], addingReplicas=[], removingReplicas=[],
isNew=true, leaderRecoveryState=0),
LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=4,
controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], partitionEpoch=0,
replicas=[0],
addingReplicas=[], removingReplicas=[], isNew=true, leaderRecoveryState=0),
LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=1,
controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], partitionEpoch=0,
replicas=[0], addingReplicas=[], removingReplicas=[], isNew=true,
leaderRecoveryState=0),
LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=2,
controllerEpoch=1, leader=0,
leaderEpoch=0, isr=[0], partitionEpoch=0, replicas=[0], addingReplicas=[],
removingReplicas=[], isNew=true, leaderRecoveryState=0)])],
liveLeaders=[LeaderAndIsrLiveLeader(brokerId=0, hostName='localhost',
port=53208)]) with context
RequestContext(header=RequestHeader(apiKey=LEADER_AND_ISR,
apiVersion=7, clientId=0, correlationId=13, headerVersion=2),
connectionId='127.0.0.1:53208-127.0.0.1:53209-0', clientAddress=/127.0.0.1,
principal=User:ANONYMOUS,
listenerName=ListenerName(PLAINTEXT), securityProtocol=PLAINTEXT,
clientInformation=ClientInformation(softwareName=unknown,
softwareVersion=unknown),
fromPrivilegedListener=true,
principalSerde=Optional[org.apache.kafka.common.security.authenticator.DefaultKafkaPrincipalBuilder@11d8de94])
org.apache.zookeeper.KeeperException$SessionExpiredException:
KeeperErrorCode = Session expired for /config/topics/__consumer_offsets
at org.apache.zookeeper.KeeperException.create(KeeperException.java:134)
at org.apache.zookeeper.KeeperException.create(KeeperException.java:54)
at
kafka.zookeeper.AsyncResponse.resultException(ZooKeeperClient.scala:555)
at kafka.zk.KafkaZkClient.getEntityConfigs(KafkaZkClient.scala:435)
at kafka.zk.AdminZkClient.fetchEntityConfig(AdminZkClient.scala:562)
at
kafka.server.metadata.ZkConfigRepository.config(ZkConfigRepository.scala:49)
at
kafka.server.metadata.ConfigRepository.topicConfig(ConfigRepository.scala:33)
at
kafka.server.metadata.ConfigRepository.topicConfig$(ConfigRepository.scala:32)
at
kafka.server.metadata.ZkConfigRepository.topicConfig(ZkConfigRepository.scala:33)
at
kafka.log.LogManager.$anonfun$fetchTopicConfigOverrides$1(LogManager.scala:590)
at
kafka.log.LogManager.$anonfun$fetchTopicConfigOverrides$1$adapted(LogManager.scala:589)
at scala.collection.immutable.Set$Set1.foreach(Set.scala:177)
at kafka.log.LogManager.fetchTopicConfigOverrides(LogManager.scala:589)
at kafka.log.LogManager.fetchLogConfig(LogManager.scala:616)
at kafka.log.LogManager.$anonfun$getOrCreateLog$1(LogManager.scala:1079)
at scala.Option.getOrElse(Option.scala:201)
at kafka.log.LogManager.getOrCreateLog(LogManager.scala:1037)
at kafka.cluster.Partition.createLog(Partition.scala:492)
at kafka.cluster.Partition.maybeCreate$1(Partition.scala:466)
at kafka.cluster.Partition.createLogIfNotExists(Partition.scala:473)
at
kafka.cluster.Partition.createLogInAssignedDirectoryId(Partition.scala:902)
at kafka.cluster.Partition.$anonfun$makeLeader$1(Partition.scala:759)
at kafka.cluster.Partition.makeLeader(Partition.scala:718)
at
kafka.server.ReplicaManager.$anonfun$makeLeaders$5(ReplicaManager.scala:2210)
at
kafka.utils.Implicits$MapExtensionMethods$.$anonfun$forKeyValue$1(Implicits.scala:62)
at scala.collection.mutable.HashMap$Node.foreachEntry(HashMap.scala:648)
at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:514)
at
kafka.server.ReplicaManager.becomeLeaderOrFollower(ReplicaManager.scala:2208)
at kafka.server.KafkaApis.handleLeaderAndIsrRequest(KafkaApis.scala:313)
at kafka.server.KafkaApis.handle(KafkaApis.scala:197)
at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:159)
at java.base/java.lang.Thread.run(Thread.java:833)
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
