[
https://issues.apache.org/jira/browse/KAFKA-12678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17943751#comment-17943751
]
Divya commented on KAFKA-12678:
-------------------------------
Hi, I'd like to work on this issue. Could you please assign it to me?
> Flaky Test CustomQuotaCallbackTest.testCustomQuotaCallback
> ----------------------------------------------------------
>
> Key: KAFKA-12678
> URL: https://issues.apache.org/jira/browse/KAFKA-12678
> Project: Kafka
> Issue Type: Test
> Components: core, unit tests
> Reporter: Matthias J. Sax
> Priority: Critical
> Labels: flaky-test
>
> https://github.com/apache/kafka/pull/10548/checks?check_run_id=2363286324
> {quote} {{org.opentest4j.AssertionFailedError: Topic [group1_largeTopic]
> metadata not propagated after 60000 ms
> at org.junit.jupiter.api.AssertionUtils.fail(AssertionUtils.java:39)
> at org.junit.jupiter.api.Assertions.fail(Assertions.java:117)
> at
> kafka.utils.TestUtils$.waitForAllPartitionsMetadata(TestUtils.scala:851)
> at kafka.utils.TestUtils$.createTopic(TestUtils.scala:410)
> at kafka.utils.TestUtils$.createTopic(TestUtils.scala:383)
> at
> kafka.api.CustomQuotaCallbackTest.createTopic(CustomQuotaCallbackTest.scala:180)
> at
> kafka.api.CustomQuotaCallbackTest.testCustomQuotaCallback(CustomQuotaCallbackTest.scala:135)}}
> {{}}{quote}
> {{STDOUT}}
> {quote}{{}}
> {{[2021-04-16 13ː59ː37,961] WARN SASL configuration failed:
> javax.security.auth.login.LoginException: No JAAS configuration section named
> 'Client' was found in specified JAAS configuration file:
> '/tmp/kafka14612759777396794548.tmp'. Will continue connection to Zookeeper
> server without SASL authentication, if Zookeeper server allows it.
> (org.apache.zookeeper.ClientCnxn:1094)
> [2021-04-16 13ː59ː37,962] ERROR [ZooKeeperClient] Auth failed.
> (kafka.zookeeper.ZooKeeperClient:74)
> [2021-04-16 13ː59ː38,367] WARN SASL configuration failed:
> javax.security.auth.login.LoginException: No JAAS configuration section named
> 'Client' was found in specified JAAS configuration file:
> '/tmp/kafka14612759777396794548.tmp'. Will continue connection to Zookeeper
> server without SASL authentication, if Zookeeper server allows it.
> (org.apache.zookeeper.ClientCnxn:1094)
> [2021-04-16 13ː59ː38,367] ERROR [ZooKeeperClient] Auth failed.
> (kafka.zookeeper.ZooKeeperClient:74)
> [2021-04-16 13ː59ː38,514] WARN SASL configuration failed:
> javax.security.auth.login.LoginException: No JAAS configuration section named
> 'Client' was found in specified JAAS configuration file:
> '/tmp/kafka14612759777396794548.tmp'. Will continue connection to Zookeeper
> server without SASL authentication, if Zookeeper server allows it.
> (org.apache.zookeeper.ClientCnxn:1094)
> [2021-04-16 13ː59ː38,514] ERROR [ZooKeeperClient Kafka server] Auth failed.
> (kafka.zookeeper.ZooKeeperClient:74)
> [2021-04-16 13ː59ː38,530] WARN No meta.properties file under dir
> /tmp/kafka-3506547187885001632/meta.properties
> (kafka.server.BrokerMetadataCheckpoint:70)
> [2021-04-16 13ː59ː38,838] WARN SASL configuration failed:
> javax.security.auth.login.LoginException: No JAAS configuration section named
> 'Client' was found in specified JAAS configuration file:
> '/tmp/kafka14612759777396794548.tmp'. Will continue connection to Zookeeper
> server without SASL authentication, if Zookeeper server allows it.
> (org.apache.zookeeper.ClientCnxn:1094)
> [2021-04-16 13ː59ː38,838] ERROR [ZooKeeperClient Kafka server] Auth failed.
> (kafka.zookeeper.ZooKeeperClient:74)
> [2021-04-16 13ː59ː38,848] WARN No meta.properties file under dir
> /tmp/kafka-15288707564978049709/meta.properties
> (kafka.server.BrokerMetadataCheckpoint:70)
> [2021-04-16 14ː00ː16,029] WARN [RequestSendThread controllerId=0] Controller
> 0 epoch 1 fails to send request (type=LeaderAndIsRequest, controllerId=0,
> controllerEpoch=1, brokerEpoch=35,
> partitionStates=[LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=6, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=72, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=39, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=14, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=80, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=47, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=22, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=88, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=55, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=30, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=96, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=63, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=38, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=5, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=71, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=46, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=13, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=79, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=54, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=21, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=87, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=62, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=29, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=95, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=4, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=70, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=37, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=12, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=78, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=45, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=20, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=86, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=53, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=28, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=94, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=61, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=36, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=3, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=69, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=44, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=11, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=77, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=52, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=19, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=85, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=60, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=27, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=93, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=2, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=68, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=35, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=10, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=76, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=43, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=18, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=84, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=51, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=26, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=92, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=59, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=34, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=1, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=67, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=42, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=9, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=75, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=50, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=17, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=83, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=58, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=25, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=91, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=0, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=66, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=33, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=8, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=74, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=41, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=16, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=82, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=49, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=24, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=90, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=57, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=32, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=98, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=65, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=40, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=7, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=73, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=48, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=15, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=81, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=56, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=23, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=89, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=64, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=31, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=97, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true)], topicIds=\{group1_largeTopic=vS9TfVAWQ3GkGorMpIhCdw},
> liveLeaders=(localhost:36121 (id: 0 rack: null))) to broker localhost:36121
> (id: 0 rack: null). Reconnecting to broker.
> (kafka.controller.RequestSendThread:72)
> java.io.IOException: Connection to 0 was disconnected before the response was
> read
> at
> org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:100)
> at
> kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:252)
> at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:96)
> [2021-04-16 14ː00ː46,074] WARN [Consumer
> clientId=group0_user1:consumer-client-id, groupId=group0_user1-group] Close
> timed out with 2 pending requests to coordinator, terminating client
> connections
> (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1019)
> [2021-04-16 14ː00ː46,077] WARN [Consumer
> clientId=group0_user2:consumer-client-id, groupId=group0_user2-group] Close
> timed out with 2 pending requests to coordinator, terminating client
> connections
> (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1019)
> [2021-04-16 14ː00ː46,078] WARN [Consumer
> clientId=group0_user3:consumer-client-id, groupId=group0_user3-group] Close
> timed out with 2 pending requests to coordinator, terminating client
> connections
> (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1019)
> [2021-04-16 14ː00ː46,080] WARN [Consumer
> clientId=group1_user1:consumer-client-id, groupId=group1_user1-group] Close
> timed out with 2 pending requests to coordinator, terminating client
> connections
> (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1019)
> [2021-04-16 14ː00ː46,120] WARN [RequestSendThread controllerId=0] Controller
> 0 epoch 1 fails to send request (type=LeaderAndIsRequest, controllerId=0,
> controllerEpoch=1, brokerEpoch=35,
> partitionStates=[LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=6, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=72, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=39, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=14, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=80, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=47, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=22, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=88, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=55, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=30, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=96, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=63, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=38, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=5, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=71, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=46, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=13, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=79, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=54, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=21, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=87, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[],
> isNew=true), LeaderAndIsrPartitionState(topicName='group1_largeTopic',
> partitionIndex=62, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0],
> zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[]…}}
> {{}}
> {quote}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
