Matthias J. Sax created KAFKA-12678:
---------------------------------------
Summary: 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
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.3.4#803005)
