[ https://issues.apache.org/jira/browse/KAFKA-8280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Guozhang Wang updated KAFKA-8280: --------------------------------- Priority: Blocker (was: Major) > Flaky Test DynamicBrokerReconfigurationTest#testUncleanLeaderElectionEnable > --------------------------------------------------------------------------- > > Key: KAFKA-8280 > URL: https://issues.apache.org/jira/browse/KAFKA-8280 > Project: Kafka > Issue Type: Bug > Affects Versions: 2.3.0 > Reporter: John Roesler > Priority: Blocker > > I saw this fail again on > https://builds.apache.org/job/kafka-pr-jdk11-scala2.12/3979/testReport/junit/kafka.server/DynamicBrokerReconfigurationTest/testUncleanLeaderElectionEnable/ > {noformat} > Error Message > java.lang.AssertionError: Unclean leader not elected > Stacktrace > java.lang.AssertionError: Unclean leader not elected > at org.junit.Assert.fail(Assert.java:88) > at org.junit.Assert.assertTrue(Assert.java:41) > at > kafka.server.DynamicBrokerReconfigurationTest.testUncleanLeaderElectionEnable(DynamicBrokerReconfigurationTest.scala:510) > {noformat} > {noformat} > Standard Output > Completed Updating config for entity: brokers '0'. > Completed Updating config for entity: brokers '1'. > Completed Updating config for entity: brokers '2'. > [2019-04-23 01:17:11,690] ERROR [ReplicaFetcher replicaId=1, leaderId=0, > fetcherId=1] Error for partition testtopic-6 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:11,690] ERROR [ReplicaFetcher replicaId=1, leaderId=0, > fetcherId=1] Error for partition testtopic-0 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:11,722] ERROR [ReplicaFetcher replicaId=2, leaderId=1, > fetcherId=0] Error for partition testtopic-7 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:11,722] ERROR [ReplicaFetcher replicaId=2, leaderId=1, > fetcherId=0] Error for partition testtopic-1 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:11,760] ERROR [ReplicaFetcher replicaId=2, leaderId=0, > fetcherId=1] Error for partition testtopic-6 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:11,761] ERROR [ReplicaFetcher replicaId=2, leaderId=0, > fetcherId=1] Error for partition testtopic-0 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:11,765] ERROR [ReplicaFetcher replicaId=2, leaderId=0, > fetcherId=0] Error for partition testtopic-3 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:11,765] ERROR [ReplicaFetcher replicaId=2, leaderId=0, > fetcherId=0] Error for partition testtopic-9 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:13,779] ERROR [ReplicaFetcher replicaId=1, leaderId=0, > fetcherId=1] Error for partition __consumer_offsets-8 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:13,780] ERROR [ReplicaFetcher replicaId=1, leaderId=0, > fetcherId=1] Error for partition __consumer_offsets-38 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:13,780] ERROR [ReplicaFetcher replicaId=1, leaderId=0, > fetcherId=1] Error for partition __consumer_offsets-2 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:13,780] ERROR [ReplicaFetcher replicaId=1, leaderId=0, > fetcherId=1] Error for partition __consumer_offsets-14 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:13,780] ERROR [ReplicaFetcher replicaId=1, leaderId=0, > fetcherId=1] Error for partition __consumer_offsets-20 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:13,780] ERROR [ReplicaFetcher replicaId=1, leaderId=0, > fetcherId=1] Error for partition __consumer_offsets-44 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:13,780] ERROR [ReplicaFetcher replicaId=1, leaderId=0, > fetcherId=1] Error for partition __consumer_offsets-26 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:13,780] ERROR [ReplicaFetcher replicaId=1, leaderId=0, > fetcherId=1] Error for partition __consumer_offsets-32 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:13,797] ERROR [ReplicaFetcher replicaId=2, leaderId=0, > fetcherId=1] Error for partition __consumer_offsets-8 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:13,798] ERROR [ReplicaFetcher replicaId=2, leaderId=0, > fetcherId=1] Error for partition __consumer_offsets-38 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:13,798] ERROR [ReplicaFetcher replicaId=2, leaderId=0, > fetcherId=1] Error for partition __consumer_offsets-2 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:13,798] ERROR [ReplicaFetcher replicaId=2, leaderId=0, > fetcherId=1] Error for partition __consumer_offsets-14 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:13,798] ERROR [ReplicaFetcher replicaId=2, leaderId=0, > fetcherId=1] Error for partition __consumer_offsets-20 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:13,798] ERROR [ReplicaFetcher replicaId=2, leaderId=0, > fetcherId=1] Error for partition __consumer_offsets-44 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:13,798] ERROR [ReplicaFetcher replicaId=2, leaderId=0, > fetcherId=1] Error for partition __consumer_offsets-26 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:13,798] ERROR [ReplicaFetcher replicaId=2, leaderId=0, > fetcherId=1] Error for partition __consumer_offsets-32 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:13,798] ERROR [ReplicaFetcher replicaId=2, leaderId=0, > fetcherId=0] Error for partition __consumer_offsets-35 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:13,798] ERROR [ReplicaFetcher replicaId=2, leaderId=0, > fetcherId=0] Error for partition __consumer_offsets-41 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:13,799] ERROR [ReplicaFetcher replicaId=2, leaderId=0, > fetcherId=0] Error for partition __consumer_offsets-23 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:13,799] ERROR [ReplicaFetcher replicaId=2, leaderId=0, > fetcherId=0] Error for partition __consumer_offsets-47 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:13,799] ERROR [ReplicaFetcher replicaId=2, leaderId=0, > fetcherId=0] Error for partition __consumer_offsets-17 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:13,799] ERROR [ReplicaFetcher replicaId=2, leaderId=0, > fetcherId=0] Error for partition __consumer_offsets-11 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:13,799] ERROR [ReplicaFetcher replicaId=2, leaderId=0, > fetcherId=0] Error for partition __consumer_offsets-5 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:13,799] ERROR [ReplicaFetcher replicaId=2, leaderId=0, > fetcherId=0] Error for partition __consumer_offsets-29 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:13,810] ERROR [ReplicaFetcher replicaId=1, leaderId=0, > fetcherId=0] Error for partition __consumer_offsets-35 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:13,810] ERROR [ReplicaFetcher replicaId=1, leaderId=0, > fetcherId=0] Error for partition __consumer_offsets-41 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:13,810] ERROR [ReplicaFetcher replicaId=1, leaderId=0, > fetcherId=0] Error for partition __consumer_offsets-23 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:13,810] ERROR [ReplicaFetcher replicaId=1, leaderId=0, > fetcherId=0] Error for partition __consumer_offsets-47 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:13,810] ERROR [ReplicaFetcher replicaId=1, leaderId=0, > fetcherId=0] Error for partition __consumer_offsets-17 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:13,810] ERROR [ReplicaFetcher replicaId=1, leaderId=0, > fetcherId=0] Error for partition __consumer_offsets-11 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:13,810] ERROR [ReplicaFetcher replicaId=1, leaderId=0, > fetcherId=0] Error for partition __consumer_offsets-5 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:13,810] ERROR [ReplicaFetcher replicaId=1, leaderId=0, > fetcherId=0] Error for partition __consumer_offsets-29 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > Completed Updating config for entity: brokers '0'. > Completed Updating config for entity: brokers '1'. > Completed Updating config for entity: brokers '2'. > [2019-04-23 01:17:24,892] ERROR [ReplicaFetcher replicaId=1, leaderId=0, > fetcherId=1] Error for partition testtopic-2 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:24,893] ERROR [ReplicaFetcher replicaId=1, leaderId=0, > fetcherId=1] Error for partition testtopic-8 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:24,930] ERROR [ReplicaFetcher replicaId=1, leaderId=2, > fetcherId=1] Error for partition testtopic-4 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:24,932] ERROR [ReplicaFetcher replicaId=2, leaderId=1, > fetcherId=0] Error for partition testtopic-3 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:24,935] ERROR [ReplicaFetcher replicaId=2, leaderId=1, > fetcherId=0] Error for partition testtopic-9 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:24,963] ERROR [ReplicaFetcher replicaId=2, leaderId=0, > fetcherId=1] Error for partition testtopic-2 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:24,963] ERROR [ReplicaFetcher replicaId=2, leaderId=0, > fetcherId=1] Error for partition testtopic-8 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:24,997] ERROR [ReplicaFetcher replicaId=0, leaderId=2, > fetcherId=1] Error for partition testtopic-4 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:25,000] ERROR [ReplicaFetcher replicaId=2, leaderId=0, > fetcherId=0] Error for partition testtopic-5 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:33,436] WARN Unable to read additional data from client > sessionid 0x1000b1c6dbb0002, likely client has closed socket > (org.apache.zookeeper.server.NIOServerCnxn:376) > [2019-04-23 01:17:33,691] WARN Unable to read additional data from client > sessionid 0x1000b1c6dbb0006, likely client has closed socket > (org.apache.zookeeper.server.NIOServerCnxn:376) > Completed Updating config for entity: brokers '0'. > Completed Updating config for entity: brokers '1'. > Completed Updating config for entity: brokers '2'. > [2019-04-23 01:17:36,468] WARN Unable to read additional data from client > sessionid 0x1000b1c9c340005, likely client has closed socket > (org.apache.zookeeper.server.NIOServerCnxn:376) > [2019-04-23 01:17:36,997] ERROR [ReplicaFetcher replicaId=2, leaderId=1, > fetcherId=0] Error for partition testtopic-3 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:36,997] ERROR [ReplicaFetcher replicaId=2, leaderId=0, > fetcherId=1] Error for partition testtopic-2 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:36,997] ERROR [ReplicaFetcher replicaId=2, leaderId=0, > fetcherId=1] Error for partition testtopic-8 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:36,998] ERROR [ReplicaFetcher replicaId=2, leaderId=1, > fetcherId=0] Error for partition testtopic-9 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:37,052] ERROR [ReplicaFetcher replicaId=2, leaderId=0, > fetcherId=0] Error for partition testtopic-5 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:37,081] ERROR [ReplicaFetcher replicaId=1, leaderId=0, > fetcherId=1] Error for partition testtopic-2 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:37,081] ERROR [ReplicaFetcher replicaId=1, leaderId=0, > fetcherId=1] Error for partition testtopic-8 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:37,090] ERROR [ReplicaFetcher replicaId=2, leaderId=1, > fetcherId=1] Error for partition testtopic-6 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:37,090] ERROR [ReplicaFetcher replicaId=2, leaderId=1, > fetcherId=1] Error for partition testtopic-0 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:37,091] ERROR [ReplicaFetcher replicaId=0, leaderId=1, > fetcherId=1] Error for partition testtopic-6 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:37,091] ERROR [ReplicaFetcher replicaId=0, leaderId=1, > fetcherId=1] Error for partition testtopic-0 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:39,101] ERROR [ReplicaFetcher replicaId=2, leaderId=1, > fetcherId=1] Error for partition __consumer_offsets-22 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:39,102] ERROR [ReplicaFetcher replicaId=2, leaderId=1, > fetcherId=1] Error for partition __consumer_offsets-4 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:39,102] ERROR [ReplicaFetcher replicaId=2, leaderId=1, > fetcherId=1] Error for partition __consumer_offsets-46 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:39,102] ERROR [ReplicaFetcher replicaId=2, leaderId=1, > fetcherId=1] Error for partition __consumer_offsets-16 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:39,102] ERROR [ReplicaFetcher replicaId=2, leaderId=1, > fetcherId=1] Error for partition __consumer_offsets-28 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:39,102] ERROR [ReplicaFetcher replicaId=2, leaderId=1, > fetcherId=1] Error for partition __consumer_offsets-34 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:39,102] ERROR [ReplicaFetcher replicaId=2, leaderId=1, > fetcherId=1] Error for partition __consumer_offsets-10 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:39,102] ERROR [ReplicaFetcher replicaId=2, leaderId=1, > fetcherId=1] Error for partition __consumer_offsets-40 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:45,444] WARN Unable to reconnect to ZooKeeper service, > session 0x1000b1c9c340002 has expired (org.apache.zookeeper.ClientCnxn:1289) > Completed Updating config for entity: brokers '0'. > Completed Updating config for entity: brokers '1'. > Completed Updating config for entity: brokers '2'. > [2019-04-23 01:17:54,406] ERROR [ReplicaFetcher replicaId=1, leaderId=2, > fetcherId=0] Error for partition testtopic-7 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:54,406] ERROR [ReplicaFetcher replicaId=1, leaderId=2, > fetcherId=0] Error for partition testtopic-1 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:54,428] ERROR [ReplicaFetcher replicaId=1, leaderId=0, > fetcherId=0] Error for partition testtopic-5 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:54,502] ERROR [ReplicaFetcher replicaId=2, leaderId=0, > fetcherId=0] Error for partition testtopic-5 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:54,502] ERROR [ReplicaFetcher replicaId=1, leaderId=2, > fetcherId=1] Error for partition testtopic-4 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:54,503] ERROR [ReplicaFetcher replicaId=1, leaderId=0, > fetcherId=1] Error for partition testtopic-2 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:54,503] ERROR [ReplicaFetcher replicaId=1, leaderId=0, > fetcherId=1] Error for partition testtopic-8 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:54,507] ERROR [ReplicaFetcher replicaId=2, leaderId=0, > fetcherId=1] Error for partition testtopic-2 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:54,507] ERROR [ReplicaFetcher replicaId=2, leaderId=0, > fetcherId=1] Error for partition testtopic-8 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:54,514] ERROR [ReplicaFetcher replicaId=0, leaderId=2, > fetcherId=0] Error for partition testtopic-7 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:54,514] ERROR [ReplicaFetcher replicaId=0, leaderId=2, > fetcherId=0] Error for partition testtopic-1 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:56,507] ERROR [ReplicaFetcher replicaId=2, leaderId=0, > fetcherId=0] Error for partition __consumer_offsets-7 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:56,508] ERROR [ReplicaFetcher replicaId=2, leaderId=0, > fetcherId=0] Error for partition __consumer_offsets-25 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:56,508] ERROR [ReplicaFetcher replicaId=2, leaderId=0, > fetcherId=0] Error for partition __consumer_offsets-49 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:56,508] ERROR [ReplicaFetcher replicaId=2, leaderId=0, > fetcherId=0] Error for partition __consumer_offsets-31 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:56,508] ERROR [ReplicaFetcher replicaId=2, leaderId=0, > fetcherId=0] Error for partition __consumer_offsets-37 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:56,508] ERROR [ReplicaFetcher replicaId=2, leaderId=0, > fetcherId=0] Error for partition __consumer_offsets-19 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:56,508] ERROR [ReplicaFetcher replicaId=2, leaderId=0, > fetcherId=0] Error for partition __consumer_offsets-13 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:56,508] ERROR [ReplicaFetcher replicaId=2, leaderId=0, > fetcherId=0] Error for partition __consumer_offsets-43 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:56,509] ERROR [ReplicaFetcher replicaId=2, leaderId=0, > fetcherId=0] Error for partition __consumer_offsets-1 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:56,519] ERROR [ReplicaFetcher replicaId=0, leaderId=1, > fetcherId=0] Error for partition __consumer_offsets-35 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:56,520] ERROR [ReplicaFetcher replicaId=0, leaderId=1, > fetcherId=0] Error for partition __consumer_offsets-41 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:56,520] ERROR [ReplicaFetcher replicaId=0, leaderId=1, > fetcherId=0] Error for partition __consumer_offsets-23 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:56,520] ERROR [ReplicaFetcher replicaId=0, leaderId=1, > fetcherId=0] Error for partition __consumer_offsets-47 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:56,520] ERROR [ReplicaFetcher replicaId=0, leaderId=1, > fetcherId=0] Error for partition __consumer_offsets-17 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:56,520] ERROR [ReplicaFetcher replicaId=0, leaderId=1, > fetcherId=0] Error for partition __consumer_offsets-11 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:56,520] ERROR [ReplicaFetcher replicaId=0, leaderId=1, > fetcherId=0] Error for partition __consumer_offsets-5 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:17:56,520] ERROR [ReplicaFetcher replicaId=0, leaderId=1, > fetcherId=0] Error for partition __consumer_offsets-29 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > Completed Updating config for entity: brokers '0'. > Completed Updating config for entity: brokers '1'. > Completed Updating config for entity: brokers '2'. > [2019-04-23 01:18:13,483] WARN Unable to read additional data from client > sessionid 0x1000b1d2d840005, likely client has closed socket > (org.apache.zookeeper.server.NIOServerCnxn:376) > [2019-04-23 01:18:14,110] ERROR [ReplicaFetcher replicaId=1, leaderId=2, > fetcherId=0] Error for partition testtopic-5 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:18:14,123] ERROR [ReplicaFetcher replicaId=1, leaderId=0, > fetcherId=1] Error for partition testtopic-6 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:18:14,124] ERROR [ReplicaFetcher replicaId=1, leaderId=0, > fetcherId=1] Error for partition testtopic-0 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:18:14,156] ERROR [ReplicaFetcher replicaId=1, leaderId=2, > fetcherId=1] Error for partition testtopic-2 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:18:14,156] ERROR [ReplicaFetcher replicaId=1, leaderId=2, > fetcherId=1] Error for partition testtopic-8 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > Completed Updating config for entity: user-principal 'scram-user'. > Completed Updating config for entity: user-principal 'scram-admin'. > [2019-04-23 01:18:20,761] WARN Unable to read additional data from client > sessionid 0x1000b1d2d840008, likely client has closed socket > (org.apache.zookeeper.server.NIOServerCnxn:376) > Debug is true storeKey true useTicketCache false useKeyTab true doNotPrompt > false ticketCache is null isInitiator true KeyTab is > /tmp/kafka13049951496002072412.tmp refreshKrb5Config is false principal is > kafka/localh...@example.com tryFirstPass is false useFirstPass is false > storePass is false clearPass is false > principal is kafka/localh...@example.com > Will use keytab > Commit Succeeded > Debug is true storeKey true useTicketCache false useKeyTab true doNotPrompt > false ticketCache is null isInitiator true KeyTab is > /tmp/kafka13049951496002072412.tmp refreshKrb5Config is false principal is > kafka/localh...@example.com tryFirstPass is false useFirstPass is false > storePass is false clearPass is false > principal is kafka/localh...@example.com > Will use keytab > Commit Succeeded > [2019-04-23 01:18:23,709] ERROR [MetadataCache brokerId=1] Listeners are not > identical across brokers: Map(0 -> Map(ListenerName(EXTERNAL) -> > localhost:43405 (id: 0 rack: null), ListenerName(INTERNAL) -> localhost:39285 > (id: 0 rack: null)), 2 -> Map(ListenerName(EXTERNAL) -> localhost:39744 (id: > 2 rack: null), ListenerName(INTERNAL) -> localhost:34976 (id: 2 rack: null)), > 1 -> Map(ListenerName(EXTERNAL) -> localhost:45747 (id: 1 rack: null), > ListenerName(INTERNAL) -> localhost:33138 (id: 1 rack: null), > ListenerName(SASL_PLAINTEXT) -> localhost:42799 (id: 1 rack: null))) > (kafka.server.MetadataCache:74) > [2019-04-23 01:18:23,712] ERROR [MetadataCache brokerId=2] Listeners are not > identical across brokers: Map(0 -> Map(ListenerName(EXTERNAL) -> > localhost:43405 (id: 0 rack: null), ListenerName(INTERNAL) -> localhost:39285 > (id: 0 rack: null)), 2 -> Map(ListenerName(EXTERNAL) -> localhost:39744 (id: > 2 rack: null), ListenerName(INTERNAL) -> localhost:34976 (id: 2 rack: null)), > 1 -> Map(ListenerName(EXTERNAL) -> localhost:45747 (id: 1 rack: null), > ListenerName(INTERNAL) -> localhost:33138 (id: 1 rack: null), > ListenerName(SASL_PLAINTEXT) -> localhost:42799 (id: 1 rack: null))) > (kafka.server.MetadataCache:74) > [2019-04-23 01:18:23,713] ERROR [MetadataCache brokerId=0] Listeners are not > identical across brokers: Map(0 -> Map(ListenerName(EXTERNAL) -> > localhost:43405 (id: 0 rack: null), ListenerName(INTERNAL) -> localhost:39285 > (id: 0 rack: null)), 2 -> Map(ListenerName(EXTERNAL) -> localhost:39744 (id: > 2 rack: null), ListenerName(INTERNAL) -> localhost:34976 (id: 2 rack: null)), > 1 -> Map(ListenerName(EXTERNAL) -> localhost:45747 (id: 1 rack: null), > ListenerName(INTERNAL) -> localhost:33138 (id: 1 rack: null), > ListenerName(SASL_PLAINTEXT) -> localhost:42799 (id: 1 rack: null))) > (kafka.server.MetadataCache:74) > [2019-04-23 01:18:23,801] ERROR [MetadataCache brokerId=0] Listeners are not > identical across brokers: Map(0 -> Map(ListenerName(EXTERNAL) -> > localhost:43405 (id: 0 rack: null), ListenerName(INTERNAL) -> localhost:39285 > (id: 0 rack: null), ListenerName(SASL_PLAINTEXT) -> localhost:34031 (id: 0 > rack: null)), 2 -> Map(ListenerName(EXTERNAL) -> localhost:39744 (id: 2 rack: > null), ListenerName(INTERNAL) -> localhost:34976 (id: 2 rack: null)), 1 -> > Map(ListenerName(EXTERNAL) -> localhost:45747 (id: 1 rack: null), > ListenerName(INTERNAL) -> localhost:33138 (id: 1 rack: null), > ListenerName(SASL_PLAINTEXT) -> localhost:42799 (id: 1 rack: null))) > (kafka.server.MetadataCache:74) > [2019-04-23 01:18:23,814] ERROR [MetadataCache brokerId=2] Listeners are not > identical across brokers: Map(0 -> Map(ListenerName(EXTERNAL) -> > localhost:43405 (id: 0 rack: null), ListenerName(INTERNAL) -> localhost:39285 > (id: 0 rack: null), ListenerName(SASL_PLAINTEXT) -> localhost:34031 (id: 0 > rack: null)), 2 -> Map(ListenerName(EXTERNAL) -> localhost:39744 (id: 2 rack: > null), ListenerName(INTERNAL) -> localhost:34976 (id: 2 rack: null)), 1 -> > Map(ListenerName(EXTERNAL) -> localhost:45747 (id: 1 rack: null), > ListenerName(INTERNAL) -> localhost:33138 (id: 1 rack: null), > ListenerName(SASL_PLAINTEXT) -> localhost:42799 (id: 1 rack: null))) > (kafka.server.MetadataCache:74) > [2019-04-23 01:18:23,825] ERROR [MetadataCache brokerId=1] Listeners are not > identical across brokers: Map(0 -> Map(ListenerName(EXTERNAL) -> > localhost:43405 (id: 0 rack: null), ListenerName(INTERNAL) -> localhost:39285 > (id: 0 rack: null), ListenerName(SASL_PLAINTEXT) -> localhost:34031 (id: 0 > rack: null)), 2 -> Map(ListenerName(EXTERNAL) -> localhost:39744 (id: 2 rack: > null), ListenerName(INTERNAL) -> localhost:34976 (id: 2 rack: null)), 1 -> > Map(ListenerName(EXTERNAL) -> localhost:45747 (id: 1 rack: null), > ListenerName(INTERNAL) -> localhost:33138 (id: 1 rack: null), > ListenerName(SASL_PLAINTEXT) -> localhost:42799 (id: 1 rack: null))) > (kafka.server.MetadataCache:74) > Debug is true storeKey true useTicketCache false useKeyTab true doNotPrompt > false ticketCache is null isInitiator true KeyTab is > /tmp/kafka13049951496002072412.tmp refreshKrb5Config is false principal is > kafka/localh...@example.com tryFirstPass is false useFirstPass is false > storePass is false clearPass is false > principal is kafka/localh...@example.com > Will use keytab > Commit Succeeded > Debug is true storeKey true useTicketCache false useKeyTab true doNotPrompt > false ticketCache is null isInitiator true KeyTab is > /tmp/kafka15031735663505492591.tmp refreshKrb5Config is false principal is > cli...@example.com tryFirstPass is false useFirstPass is false storePass is > false clearPass is false > principal is cli...@example.com > Will use keytab > Commit Succeeded > [2019-04-23 01:18:25,292] ERROR [MetadataCache brokerId=0] Listeners are not > identical across brokers: Map(0 -> Map(ListenerName(EXTERNAL) -> > localhost:43405 (id: 0 rack: null), ListenerName(INTERNAL) -> localhost:39285 > (id: 0 rack: null)), 2 -> Map(ListenerName(EXTERNAL) -> localhost:39744 (id: > 2 rack: null), ListenerName(INTERNAL) -> localhost:34976 (id: 2 rack: null), > ListenerName(SASL_PLAINTEXT) -> localhost:42715 (id: 2 rack: null)), 1 -> > Map(ListenerName(EXTERNAL) -> localhost:45747 (id: 1 rack: null), > ListenerName(INTERNAL) -> localhost:33138 (id: 1 rack: null), > ListenerName(SASL_PLAINTEXT) -> localhost:42799 (id: 1 rack: null))) > (kafka.server.MetadataCache:74) > [2019-04-23 01:18:25,296] ERROR [MetadataCache brokerId=1] Listeners are not > identical across brokers: Map(0 -> Map(ListenerName(EXTERNAL) -> > localhost:43405 (id: 0 rack: null), ListenerName(INTERNAL) -> localhost:39285 > (id: 0 rack: null)), 2 -> Map(ListenerName(EXTERNAL) -> localhost:39744 (id: > 2 rack: null), ListenerName(INTERNAL) -> localhost:34976 (id: 2 rack: null), > ListenerName(SASL_PLAINTEXT) -> localhost:42715 (id: 2 rack: null)), 1 -> > Map(ListenerName(EXTERNAL) -> localhost:45747 (id: 1 rack: null), > ListenerName(INTERNAL) -> localhost:33138 (id: 1 rack: null), > ListenerName(SASL_PLAINTEXT) -> localhost:42799 (id: 1 rack: null))) > (kafka.server.MetadataCache:74) > [2019-04-23 01:18:25,310] ERROR [MetadataCache brokerId=2] Listeners are not > identical across brokers: Map(0 -> Map(ListenerName(EXTERNAL) -> > localhost:43405 (id: 0 rack: null), ListenerName(INTERNAL) -> localhost:39285 > (id: 0 rack: null)), 2 -> Map(ListenerName(EXTERNAL) -> localhost:39744 (id: > 2 rack: null), ListenerName(INTERNAL) -> localhost:34976 (id: 2 rack: null), > ListenerName(SASL_PLAINTEXT) -> localhost:42715 (id: 2 rack: null)), 1 -> > Map(ListenerName(EXTERNAL) -> localhost:45747 (id: 1 rack: null), > ListenerName(INTERNAL) -> localhost:33138 (id: 1 rack: null), > ListenerName(SASL_PLAINTEXT) -> localhost:42799 (id: 1 rack: null))) > (kafka.server.MetadataCache:74) > [2019-04-23 01:18:25,326] ERROR [MetadataCache brokerId=1] Listeners are not > identical across brokers: Map(0 -> Map(ListenerName(EXTERNAL) -> > localhost:43405 (id: 0 rack: null), ListenerName(INTERNAL) -> localhost:39285 > (id: 0 rack: null)), 2 -> Map(ListenerName(EXTERNAL) -> localhost:39744 (id: > 2 rack: null), ListenerName(INTERNAL) -> localhost:34976 (id: 2 rack: null), > ListenerName(SASL_PLAINTEXT) -> localhost:42715 (id: 2 rack: null)), 1 -> > Map(ListenerName(EXTERNAL) -> localhost:45747 (id: 1 rack: null), > ListenerName(INTERNAL) -> localhost:33138 (id: 1 rack: null))) > (kafka.server.MetadataCache:74) > [2019-04-23 01:18:25,348] ERROR [MetadataCache brokerId=0] Listeners are not > identical across brokers: Map(0 -> Map(ListenerName(EXTERNAL) -> > localhost:43405 (id: 0 rack: null), ListenerName(INTERNAL) -> localhost:39285 > (id: 0 rack: null)), 2 -> Map(ListenerName(EXTERNAL) -> localhost:39744 (id: > 2 rack: null), ListenerName(INTERNAL) -> localhost:34976 (id: 2 rack: null), > ListenerName(SASL_PLAINTEXT) -> localhost:42715 (id: 2 rack: null)), 1 -> > Map(ListenerName(EXTERNAL) -> localhost:45747 (id: 1 rack: null), > ListenerName(INTERNAL) -> localhost:33138 (id: 1 rack: null))) > (kafka.server.MetadataCache:74) > [2019-04-23 01:18:25,356] ERROR [MetadataCache brokerId=2] Listeners are not > identical across brokers: Map(0 -> Map(ListenerName(EXTERNAL) -> > localhost:43405 (id: 0 rack: null), ListenerName(INTERNAL) -> localhost:39285 > (id: 0 rack: null)), 2 -> Map(ListenerName(EXTERNAL) -> localhost:39744 (id: > 2 rack: null), ListenerName(INTERNAL) -> localhost:34976 (id: 2 rack: null), > ListenerName(SASL_PLAINTEXT) -> localhost:42715 (id: 2 rack: null)), 1 -> > Map(ListenerName(EXTERNAL) -> localhost:45747 (id: 1 rack: null), > ListenerName(INTERNAL) -> localhost:33138 (id: 1 rack: null))) > (kafka.server.MetadataCache:74) > [2019-04-23 01:18:28,355] ERROR [MetadataCache brokerId=0] Listeners are not > identical across brokers: Map(0 -> Map(ListenerName(EXTERNAL) -> > localhost:43405 (id: 0 rack: null), ListenerName(INTERNAL) -> localhost:39285 > (id: 0 rack: null)), 2 -> Map(ListenerName(EXTERNAL) -> localhost:39744 (id: > 2 rack: null), ListenerName(INTERNAL) -> localhost:34976 (id: 2 rack: null)), > 1 -> Map(ListenerName(EXTERNAL) -> localhost:45747 (id: 1 rack: null), > ListenerName(INTERNAL) -> localhost:33138 (id: 1 rack: null), > ListenerName(SCRAM_LISTENER) -> localhost:39637 (id: 1 rack: null))) > (kafka.server.MetadataCache:74) > [2019-04-23 01:18:28,362] ERROR [MetadataCache brokerId=1] Listeners are not > identical across brokers: Map(0 -> Map(ListenerName(EXTERNAL) -> > localhost:43405 (id: 0 rack: null), ListenerName(INTERNAL) -> localhost:39285 > (id: 0 rack: null)), 2 -> Map(ListenerName(EXTERNAL) -> localhost:39744 (id: > 2 rack: null), ListenerName(INTERNAL) -> localhost:34976 (id: 2 rack: null)), > 1 -> Map(ListenerName(EXTERNAL) -> localhost:45747 (id: 1 rack: null), > ListenerName(INTERNAL) -> localhost:33138 (id: 1 rack: null), > ListenerName(SCRAM_LISTENER) -> localhost:39637 (id: 1 rack: null))) > (kafka.server.MetadataCache:74) > [2019-04-23 01:18:28,357] ERROR [MetadataCache brokerId=2] Listeners are not > identical across brokers: Map(0 -> Map(ListenerName(EXTERNAL) -> > localhost:43405 (id: 0 rack: null), ListenerName(INTERNAL) -> localhost:39285 > (id: 0 rack: null)), 2 -> Map(ListenerName(EXTERNAL) -> localhost:39744 (id: > 2 rack: null), ListenerName(INTERNAL) -> localhost:34976 (id: 2 rack: null)), > 1 -> Map(ListenerName(EXTERNAL) -> localhost:45747 (id: 1 rack: null), > ListenerName(INTERNAL) -> localhost:33138 (id: 1 rack: null), > ListenerName(SCRAM_LISTENER) -> localhost:39637 (id: 1 rack: null))) > (kafka.server.MetadataCache:74) > [2019-04-23 01:18:28,451] ERROR [MetadataCache brokerId=2] Listeners are not > identical across brokers: Map(0 -> Map(ListenerName(EXTERNAL) -> > localhost:43405 (id: 0 rack: null), ListenerName(INTERNAL) -> localhost:39285 > (id: 0 rack: null)), 2 -> Map(ListenerName(EXTERNAL) -> localhost:39744 (id: > 2 rack: null), ListenerName(INTERNAL) -> localhost:34976 (id: 2 rack: null), > ListenerName(SCRAM_LISTENER) -> localhost:34765 (id: 2 rack: null)), 1 -> > Map(ListenerName(EXTERNAL) -> localhost:45747 (id: 1 rack: null), > ListenerName(INTERNAL) -> localhost:33138 (id: 1 rack: null), > ListenerName(SCRAM_LISTENER) -> localhost:39637 (id: 1 rack: null))) > (kafka.server.MetadataCache:74) > [2019-04-23 01:18:28,456] ERROR [MetadataCache brokerId=0] Listeners are not > identical across brokers: Map(0 -> Map(ListenerName(EXTERNAL) -> > localhost:43405 (id: 0 rack: null), ListenerName(INTERNAL) -> localhost:39285 > (id: 0 rack: null)), 2 -> Map(ListenerName(EXTERNAL) -> localhost:39744 (id: > 2 rack: null), ListenerName(INTERNAL) -> localhost:34976 (id: 2 rack: null), > ListenerName(SCRAM_LISTENER) -> localhost:34765 (id: 2 rack: null)), 1 -> > Map(ListenerName(EXTERNAL) -> localhost:45747 (id: 1 rack: null), > ListenerName(INTERNAL) -> localhost:33138 (id: 1 rack: null), > ListenerName(SCRAM_LISTENER) -> localhost:39637 (id: 1 rack: null))) > (kafka.server.MetadataCache:74) > [2019-04-23 01:18:28,457] ERROR [MetadataCache brokerId=1] Listeners are not > identical across brokers: Map(0 -> Map(ListenerName(EXTERNAL) -> > localhost:43405 (id: 0 rack: null), ListenerName(INTERNAL) -> localhost:39285 > (id: 0 rack: null)), 2 -> Map(ListenerName(EXTERNAL) -> localhost:39744 (id: > 2 rack: null), ListenerName(INTERNAL) -> localhost:34976 (id: 2 rack: null), > ListenerName(SCRAM_LISTENER) -> localhost:34765 (id: 2 rack: null)), 1 -> > Map(ListenerName(EXTERNAL) -> localhost:45747 (id: 1 rack: null), > ListenerName(INTERNAL) -> localhost:33138 (id: 1 rack: null), > ListenerName(SCRAM_LISTENER) -> localhost:39637 (id: 1 rack: null))) > (kafka.server.MetadataCache:74) > [2019-04-23 01:18:28,685] ERROR [MetadataCache brokerId=1] Listeners are not > identical across brokers: Map(0 -> Map(ListenerName(EXTERNAL) -> > localhost:43405 (id: 0 rack: null), ListenerName(INTERNAL) -> localhost:39285 > (id: 0 rack: null)), 2 -> Map(ListenerName(EXTERNAL) -> localhost:39744 (id: > 2 rack: null), ListenerName(INTERNAL) -> localhost:34976 (id: 2 rack: null), > ListenerName(SCRAM_LISTENER) -> localhost:34765 (id: 2 rack: null)), 1 -> > Map(ListenerName(EXTERNAL) -> localhost:45747 (id: 1 rack: null), > ListenerName(INTERNAL) -> localhost:33138 (id: 1 rack: null), > ListenerName(SCRAM_LISTENER) -> localhost:39637 (id: 1 rack: null))) > (kafka.server.MetadataCache:74) > [2019-04-23 01:18:28,755] ERROR [MetadataCache brokerId=2] Listeners are not > identical across brokers: Map(0 -> Map(ListenerName(EXTERNAL) -> > localhost:43405 (id: 0 rack: null), ListenerName(INTERNAL) -> localhost:39285 > (id: 0 rack: null)), 2 -> Map(ListenerName(EXTERNAL) -> localhost:39744 (id: > 2 rack: null), ListenerName(INTERNAL) -> localhost:34976 (id: 2 rack: null), > ListenerName(SCRAM_LISTENER) -> localhost:34765 (id: 2 rack: null)), 1 -> > Map(ListenerName(EXTERNAL) -> localhost:45747 (id: 1 rack: null), > ListenerName(INTERNAL) -> localhost:33138 (id: 1 rack: null), > ListenerName(SCRAM_LISTENER) -> localhost:39637 (id: 1 rack: null))) > (kafka.server.MetadataCache:74) > [2019-04-23 01:18:28,787] ERROR [MetadataCache brokerId=0] Listeners are not > identical across brokers: Map(0 -> Map(ListenerName(EXTERNAL) -> > localhost:43405 (id: 0 rack: null), ListenerName(INTERNAL) -> localhost:39285 > (id: 0 rack: null)), 2 -> Map(ListenerName(EXTERNAL) -> localhost:39744 (id: > 2 rack: null), ListenerName(INTERNAL) -> localhost:34976 (id: 2 rack: null), > ListenerName(SCRAM_LISTENER) -> localhost:34765 (id: 2 rack: null)), 1 -> > Map(ListenerName(EXTERNAL) -> localhost:45747 (id: 1 rack: null), > ListenerName(INTERNAL) -> localhost:33138 (id: 1 rack: null), > ListenerName(SCRAM_LISTENER) -> localhost:39637 (id: 1 rack: null))) > (kafka.server.MetadataCache:74) > [2019-04-23 01:18:29,041] ERROR [MetadataCache brokerId=2] Listeners are not > identical across brokers: Map(0 -> Map(ListenerName(EXTERNAL) -> > localhost:43405 (id: 0 rack: null), ListenerName(INTERNAL) -> localhost:39285 > (id: 0 rack: null)), 2 -> Map(ListenerName(EXTERNAL) -> localhost:39744 (id: > 2 rack: null), ListenerName(INTERNAL) -> localhost:34976 (id: 2 rack: null), > ListenerName(SCRAM_LISTENER) -> localhost:34765 (id: 2 rack: null)), 1 -> > Map(ListenerName(EXTERNAL) -> localhost:45747 (id: 1 rack: null), > ListenerName(INTERNAL) -> localhost:33138 (id: 1 rack: null), > ListenerName(SCRAM_LISTENER) -> localhost:39637 (id: 1 rack: null))) > (kafka.server.MetadataCache:74) > [2019-04-23 01:18:29,832] WARN Unable to read additional data from client > sessionid 0x1000b1d2d840002, likely client has closed socket > (org.apache.zookeeper.server.NIOServerCnxn:376) > Completed Updating config for entity: brokers '0'. > Completed Updating config for entity: brokers '1'. > Completed Updating config for entity: brokers '2'. > [2019-04-23 01:18:35,385] WARN Unable to read additional data from client > sessionid 0x1000b1d7e280005, likely client has closed socket > (org.apache.zookeeper.server.NIOServerCnxn:376) > [2019-04-23 01:18:36,532] ERROR [ReplicaFetcher replicaId=2, leaderId=1, > fetcherId=0] Error for partition testtopic-5 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:18:36,550] ERROR [ReplicaFetcher replicaId=1, leaderId=2, > fetcherId=0] Error for partition testtopic-3 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:18:36,550] ERROR [ReplicaFetcher replicaId=1, leaderId=2, > fetcherId=0] Error for partition testtopic-9 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:18:36,553] ERROR [ReplicaFetcher replicaId=2, leaderId=0, > fetcherId=1] Error for partition testtopic-4 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:18:36,560] ERROR [ReplicaFetcher replicaId=2, leaderId=0, > fetcherId=0] Error for partition testtopic-7 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:18:36,560] ERROR [ReplicaFetcher replicaId=2, leaderId=0, > fetcherId=0] Error for partition testtopic-1 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:18:36,629] ERROR [ReplicaFetcher replicaId=1, leaderId=0, > fetcherId=0] Error for partition testtopic-7 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:18:36,637] ERROR [ReplicaFetcher replicaId=1, leaderId=0, > fetcherId=0] Error for partition testtopic-1 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:18:43,292] ERROR [Producer clientId=test-client] Connection to > node -3 (localhost/127.0.0.1:34345) failed authentication due to: SSL > handshake failed (org.apache.kafka.clients.NetworkClient:713) > [2019-04-23 01:18:43,293] ERROR [Producer clientId=test-client] Connection to > node -1 (localhost/127.0.0.1:42641) failed authentication due to: SSL > handshake failed (org.apache.kafka.clients.NetworkClient:713) > [2019-04-23 01:18:43,293] ERROR [Producer clientId=test-client] Connection to > node -2 (localhost/127.0.0.1:33177) failed authentication due to: SSL > handshake failed (org.apache.kafka.clients.NetworkClient:713) > [2019-04-23 01:18:43,478] ERROR [Producer clientId=test-client] Connection to > node -2 (localhost/127.0.0.1:33177) failed authentication due to: SSL > handshake failed (org.apache.kafka.clients.NetworkClient:713) > [2019-04-23 01:18:43,541] ERROR [Producer clientId=test-client] Connection to > node -1 (localhost/127.0.0.1:42641) failed authentication due to: SSL > handshake failed (org.apache.kafka.clients.NetworkClient:713) > [2019-04-23 01:18:43,681] ERROR [Producer clientId=test-client] Connection to > node -3 (localhost/127.0.0.1:34345) failed authentication due to: SSL > handshake failed (org.apache.kafka.clients.NetworkClient:713) > [2019-04-23 01:18:43,938] ERROR [Producer clientId=test-client] Connection to > node -2 (localhost/127.0.0.1:33177) failed authentication due to: SSL > handshake failed (org.apache.kafka.clients.NetworkClient:713) > [2019-04-23 01:18:43,973] ERROR [Producer clientId=test-client] Connection to > node -1 (localhost/127.0.0.1:42641) failed authentication due to: SSL > handshake failed (org.apache.kafka.clients.NetworkClient:713) > [2019-04-23 01:18:44,211] ERROR [Producer clientId=test-client] Connection to > node -3 (localhost/127.0.0.1:34345) failed authentication due to: SSL > handshake failed (org.apache.kafka.clients.NetworkClient:713) > [2019-04-23 01:18:46,711] ERROR [Producer clientId=test-client] Connection to > node -2 (localhost/127.0.0.1:33177) failed authentication due to: SSL > handshake failed (org.apache.kafka.clients.NetworkClient:713) > [2019-04-23 01:18:46,712] ERROR [Producer clientId=test-client] Connection to > node -1 (localhost/127.0.0.1:42641) failed authentication due to: SSL > handshake failed (org.apache.kafka.clients.NetworkClient:713) > [2019-04-23 01:18:46,721] ERROR [Producer clientId=test-client] Connection to > node -3 (localhost/127.0.0.1:34345) failed authentication due to: SSL > handshake failed (org.apache.kafka.clients.NetworkClient:713) > [2019-04-23 01:18:46,848] ERROR [Producer clientId=test-client] Connection to > node -1 (localhost/127.0.0.1:42641) failed authentication due to: SSL > handshake failed (org.apache.kafka.clients.NetworkClient:713) > [2019-04-23 01:18:46,862] ERROR [Producer clientId=test-client] Connection to > node -2 (localhost/127.0.0.1:33177) failed authentication due to: SSL > handshake failed (org.apache.kafka.clients.NetworkClient:713) > [2019-04-23 01:18:46,863] ERROR [Producer clientId=test-client] Connection to > node -3 (localhost/127.0.0.1:34345) failed authentication due to: SSL > handshake failed (org.apache.kafka.clients.NetworkClient:713) > [2019-04-23 01:18:47,382] ERROR [Producer clientId=test-client] Connection to > node -1 (localhost/127.0.0.1:42641) failed authentication due to: SSL > handshake failed (org.apache.kafka.clients.NetworkClient:713) > [2019-04-23 01:18:47,417] ERROR [Producer clientId=test-client] Connection to > node -2 (localhost/127.0.0.1:33177) failed authentication due to: SSL > handshake failed (org.apache.kafka.clients.NetworkClient:713) > [2019-04-23 01:18:47,417] ERROR [Producer clientId=test-client] Connection to > node -3 (localhost/127.0.0.1:34345) failed authentication due to: SSL > handshake failed (org.apache.kafka.clients.NetworkClient:713) > Completed Updating config for entity: brokers '0'. > Completed Updating config for entity: brokers '1'. > Completed Updating config for entity: brokers '2'. > [2019-04-23 01:18:54,690] ERROR [ReplicaFetcher replicaId=0, leaderId=1, > fetcherId=1] Error for partition testtopic-6 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:18:54,690] ERROR [ReplicaFetcher replicaId=0, leaderId=1, > fetcherId=1] Error for partition testtopic-0 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:18:54,712] ERROR [ReplicaFetcher replicaId=1, leaderId=0, > fetcherId=1] Error for partition testtopic-2 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:18:54,713] ERROR [ReplicaFetcher replicaId=1, leaderId=0, > fetcherId=1] Error for partition testtopic-8 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:18:54,716] ERROR [ReplicaFetcher replicaId=0, leaderId=2, > fetcherId=1] Error for partition testtopic-4 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:18:54,744] ERROR [ReplicaFetcher replicaId=2, leaderId=0, > fetcherId=0] Error for partition testtopic-5 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:18:54,744] ERROR [ReplicaFetcher replicaId=1, leaderId=0, > fetcherId=0] Error for partition testtopic-5 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:18:54,746] ERROR [ReplicaFetcher replicaId=1, leaderId=2, > fetcherId=0] Error for partition testtopic-7 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:18:54,747] ERROR [ReplicaFetcher replicaId=1, leaderId=2, > fetcherId=0] Error for partition testtopic-1 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > Completed Updating config for entity: brokers '0'. > Completed Updating config for entity: brokers '1'. > Completed Updating config for entity: brokers '2'. > [2019-04-23 01:19:27,114] ERROR [ReplicaFetcher replicaId=1, leaderId=2, > fetcherId=1] Error for partition testtopic-6 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:19:27,114] ERROR [ReplicaFetcher replicaId=1, leaderId=2, > fetcherId=1] Error for partition testtopic-0 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:19:27,180] ERROR [ReplicaFetcher replicaId=1, leaderId=0, > fetcherId=1] Error for partition testtopic-4 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:19:27,216] ERROR [ReplicaFetcher replicaId=1, leaderId=0, > fetcherId=0] Error for partition testtopic-7 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:19:27,219] ERROR [ReplicaFetcher replicaId=1, leaderId=0, > fetcherId=0] Error for partition testtopic-1 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:19:27,240] ERROR [ReplicaFetcher replicaId=2, leaderId=0, > fetcherId=1] Error for partition testtopic-4 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:19:29,158] ERROR [ReplicaFetcher replicaId=1, leaderId=2, > fetcherId=1] Error for partition __consumer_offsets-22 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:19:29,158] ERROR [ReplicaFetcher replicaId=1, leaderId=2, > fetcherId=1] Error for partition __consumer_offsets-4 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:19:29,158] ERROR [ReplicaFetcher replicaId=1, leaderId=2, > fetcherId=1] Error for partition __consumer_offsets-46 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:19:29,158] ERROR [ReplicaFetcher replicaId=1, leaderId=2, > fetcherId=1] Error for partition __consumer_offsets-16 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:19:29,158] ERROR [ReplicaFetcher replicaId=1, leaderId=2, > fetcherId=1] Error for partition __consumer_offsets-28 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:19:29,158] ERROR [ReplicaFetcher replicaId=1, leaderId=2, > fetcherId=1] Error for partition __consumer_offsets-34 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:19:29,159] ERROR [ReplicaFetcher replicaId=1, leaderId=2, > fetcherId=1] Error for partition __consumer_offsets-10 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:19:29,159] ERROR [ReplicaFetcher replicaId=1, leaderId=2, > fetcherId=1] Error for partition __consumer_offsets-40 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:19:35,323] ERROR [Producer clientId=test-client] Connection to > node -2 (localhost/127.0.0.1:41691) failed authentication due to: SSL > handshake failed (org.apache.kafka.clients.NetworkClient:713) > [2019-04-23 01:19:35,333] ERROR [Producer clientId=test-client] Connection to > node -1 (localhost/127.0.0.1:39180) failed authentication due to: SSL > handshake failed (org.apache.kafka.clients.NetworkClient:713) > [2019-04-23 01:19:35,333] ERROR [Producer clientId=test-client] Connection to > node -3 (localhost/127.0.0.1:43485) failed authentication due to: SSL > handshake failed (org.apache.kafka.clients.NetworkClient:713) > [2019-04-23 01:19:35,449] ERROR [Producer clientId=test-client] Connection to > node -2 (localhost/127.0.0.1:41691) failed authentication due to: SSL > handshake failed (org.apache.kafka.clients.NetworkClient:713) > [2019-04-23 01:19:35,461] ERROR [Producer clientId=test-client] Connection to > node -3 (localhost/127.0.0.1:43485) failed authentication due to: SSL > handshake failed (org.apache.kafka.clients.NetworkClient:713) > Completed updating config for broker: 0. > [2019-04-23 01:19:35,572] ERROR [Producer clientId=test-client] Connection to > node -1 (localhost/127.0.0.1:39180) failed authentication due to: SSL > handshake failed (org.apache.kafka.clients.NetworkClient:713) > Completed updating config for broker: 1. > [2019-04-23 01:19:35,919] ERROR [Producer clientId=test-client] Connection to > node -3 (localhost/127.0.0.1:43485) failed authentication due to: SSL > handshake failed (org.apache.kafka.clients.NetworkClient:713) > Completed updating config for broker: 2. > [2019-04-23 01:19:36,065] ERROR [Producer clientId=test-client] Connection to > node -2 (localhost/127.0.0.1:41691) failed authentication due to: SSL > handshake failed (org.apache.kafka.clients.NetworkClient:713) > [2019-04-23 01:19:36,071] ERROR [Producer clientId=test-client] Connection to > node -1 (localhost/127.0.0.1:39180) failed authentication due to: SSL > handshake failed (org.apache.kafka.clients.NetworkClient:713) > [2019-04-23 01:19:36,072] ERROR [Producer clientId=test-client] Connection to > node -3 (localhost/127.0.0.1:43485) failed authentication due to: SSL > handshake failed (org.apache.kafka.clients.NetworkClient:713) > [2019-04-23 01:19:36,181] ERROR [Producer clientId=test-client] Connection to > node -2 (localhost/127.0.0.1:41691) failed authentication due to: SSL > handshake failed (org.apache.kafka.clients.NetworkClient:713) > [2019-04-23 01:19:36,181] ERROR [Producer clientId=test-client] Connection to > node -3 (localhost/127.0.0.1:43485) failed authentication due to: SSL > handshake failed (org.apache.kafka.clients.NetworkClient:713) > [2019-04-23 01:19:36,184] ERROR [Producer clientId=test-client] Connection to > node -1 (localhost/127.0.0.1:39180) failed authentication due to: SSL > handshake failed (org.apache.kafka.clients.NetworkClient:713) > [2019-04-23 01:19:36,518] ERROR [Producer clientId=test-client] Connection to > node -1 (localhost/127.0.0.1:39180) failed authentication due to: SSL > handshake failed (org.apache.kafka.clients.NetworkClient:713) > [2019-04-23 01:19:36,624] ERROR [Producer clientId=test-client] Connection to > node -2 (localhost/127.0.0.1:41691) failed authentication due to: SSL > handshake failed (org.apache.kafka.clients.NetworkClient:713) > [2019-04-23 01:19:36,730] ERROR [Producer clientId=test-client] Connection to > node -3 (localhost/127.0.0.1:43485) failed authentication due to: SSL > handshake failed (org.apache.kafka.clients.NetworkClient:713) > [2019-04-23 01:19:37,589] ERROR [Producer clientId=test-client] Connection to > node -3 (localhost/127.0.0.1:43485) failed authentication due to: SSL > handshake failed (org.apache.kafka.clients.NetworkClient:713) > [2019-04-23 01:19:37,702] ERROR [Producer clientId=test-client] Connection to > node -2 (localhost/127.0.0.1:41691) failed authentication due to: SSL > handshake failed (org.apache.kafka.clients.NetworkClient:713) > [2019-04-23 01:19:37,711] ERROR [Producer clientId=test-client] Connection to > node -1 (localhost/127.0.0.1:39180) failed authentication due to: SSL > handshake failed (org.apache.kafka.clients.NetworkClient:713) > [2019-04-23 01:19:38,627] ERROR [Producer clientId=test-client] Connection to > node -2 (localhost/127.0.0.1:41691) failed authentication due to: SSL > handshake failed (org.apache.kafka.clients.NetworkClient:713) > [2019-04-23 01:19:38,630] ERROR [Producer clientId=test-client] Connection to > node -3 (localhost/127.0.0.1:43485) failed authentication due to: SSL > handshake failed (org.apache.kafka.clients.NetworkClient:713) > [2019-04-23 01:19:38,816] ERROR [Producer clientId=test-client] Connection to > node -1 (localhost/127.0.0.1:39180) failed authentication due to: SSL > handshake failed (org.apache.kafka.clients.NetworkClient:713) > [2019-04-23 01:19:40,883] ERROR [Producer clientId=test-client] Connection to > node -3 (localhost/127.0.0.1:43485) failed authentication due to: SSL > handshake failed (org.apache.kafka.clients.NetworkClient:713) > [2019-04-23 01:19:40,890] ERROR [Producer clientId=test-client] Connection to > node -2 (localhost/127.0.0.1:41691) failed authentication due to: SSL > handshake failed (org.apache.kafka.clients.NetworkClient:713) > [2019-04-23 01:19:40,891] ERROR [Producer clientId=test-client] Connection to > node -1 (localhost/127.0.0.1:39180) failed authentication due to: SSL > handshake failed (org.apache.kafka.clients.NetworkClient:713) > Completed Updating config for entity: brokers '0'. > Completed Updating config for entity: brokers '1'. > Completed Updating config for entity: brokers '2'. > [2019-04-23 01:19:47,671] ERROR [ReplicaFetcher replicaId=2, leaderId=1, > fetcherId=1] Error for partition testtopic-2 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:19:47,671] ERROR [ReplicaFetcher replicaId=2, leaderId=1, > fetcherId=1] Error for partition testtopic-8 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:19:47,691] ERROR [ReplicaFetcher replicaId=2, leaderId=1, > fetcherId=0] Error for partition testtopic-5 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:19:47,724] ERROR [ReplicaFetcher replicaId=0, leaderId=1, > fetcherId=0] Error for partition testtopic-5 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:19:47,727] ERROR [ReplicaFetcher replicaId=0, leaderId=2, > fetcherId=0] Error for partition testtopic-3 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:19:47,727] ERROR [ReplicaFetcher replicaId=0, leaderId=2, > fetcherId=0] Error for partition testtopic-9 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:19:47,757] ERROR [ReplicaFetcher replicaId=2, leaderId=0, > fetcherId=0] Error for partition testtopic-7 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:19:47,757] ERROR [ReplicaFetcher replicaId=2, leaderId=0, > fetcherId=0] Error for partition testtopic-1 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:19:47,798] ERROR [ReplicaFetcher replicaId=0, leaderId=1, > fetcherId=1] Error for partition testtopic-2 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:19:47,799] ERROR [ReplicaFetcher replicaId=0, leaderId=1, > fetcherId=1] Error for partition testtopic-8 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:19:49,706] ERROR [ReplicaFetcher replicaId=2, leaderId=1, > fetcherId=1] Error for partition __consumer_offsets-22 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:19:49,707] ERROR [ReplicaFetcher replicaId=2, leaderId=1, > fetcherId=1] Error for partition __consumer_offsets-4 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:19:49,707] ERROR [ReplicaFetcher replicaId=2, leaderId=1, > fetcherId=1] Error for partition __consumer_offsets-46 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:19:49,707] ERROR [ReplicaFetcher replicaId=2, leaderId=1, > fetcherId=1] Error for partition __consumer_offsets-16 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:19:49,707] ERROR [ReplicaFetcher replicaId=2, leaderId=1, > fetcherId=1] Error for partition __consumer_offsets-28 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:19:49,707] ERROR [ReplicaFetcher replicaId=2, leaderId=1, > fetcherId=1] Error for partition __consumer_offsets-34 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:19:49,707] ERROR [ReplicaFetcher replicaId=2, leaderId=1, > fetcherId=1] Error for partition __consumer_offsets-10 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:19:49,707] ERROR [ReplicaFetcher replicaId=2, leaderId=1, > fetcherId=1] Error for partition __consumer_offsets-40 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:19:49,717] ERROR [ReplicaFetcher replicaId=2, leaderId=1, > fetcherId=0] Error for partition __consumer_offsets-7 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:19:49,717] ERROR [ReplicaFetcher replicaId=2, leaderId=1, > fetcherId=0] Error for partition __consumer_offsets-25 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:19:49,717] ERROR [ReplicaFetcher replicaId=2, leaderId=1, > fetcherId=0] Error for partition __consumer_offsets-49 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:19:49,717] ERROR [ReplicaFetcher replicaId=2, leaderId=1, > fetcherId=0] Error for partition __consumer_offsets-31 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:19:49,717] ERROR [ReplicaFetcher replicaId=2, leaderId=1, > fetcherId=0] Error for partition __consumer_offsets-37 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:19:49,717] ERROR [ReplicaFetcher replicaId=2, leaderId=1, > fetcherId=0] Error for partition __consumer_offsets-19 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:19:49,717] ERROR [ReplicaFetcher replicaId=2, leaderId=1, > fetcherId=0] Error for partition __consumer_offsets-13 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:19:49,717] ERROR [ReplicaFetcher replicaId=2, leaderId=1, > fetcherId=0] Error for partition __consumer_offsets-43 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:19:49,717] ERROR [ReplicaFetcher replicaId=2, leaderId=1, > fetcherId=0] Error for partition __consumer_offsets-1 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > Completed updating config for broker: 0. > Completed updating config for broker: 1. > Completed updating config for broker: 2. > Completed Updating config for entity: brokers '0'. > Completed Updating config for entity: brokers '1'. > Completed Updating config for entity: brokers '2'. > [2019-04-23 01:19:59,638] ERROR [ReplicaFetcher replicaId=0, leaderId=1, > fetcherId=1] Error for partition testtopic-6 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:19:59,638] ERROR [ReplicaFetcher replicaId=0, leaderId=1, > fetcherId=1] Error for partition testtopic-0 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:19:59,639] ERROR [ReplicaFetcher replicaId=0, leaderId=1, > fetcherId=0] Error for partition testtopic-3 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:19:59,639] ERROR [ReplicaFetcher replicaId=0, leaderId=1, > fetcherId=0] Error for partition testtopic-9 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:19:59,698] ERROR [ReplicaFetcher replicaId=2, leaderId=1, > fetcherId=1] Error for partition testtopic-6 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:19:59,699] ERROR [ReplicaFetcher replicaId=2, leaderId=1, > fetcherId=1] Error for partition testtopic-0 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:19:59,700] ERROR [ReplicaFetcher replicaId=2, leaderId=1, > fetcherId=0] Error for partition testtopic-3 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:19:59,700] ERROR [ReplicaFetcher replicaId=2, leaderId=1, > fetcherId=0] Error for partition testtopic-9 at offset 0 > (kafka.server.ReplicaFetcherThread:76) > org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server > does not host this topic-partition. > [2019-04-23 01:20:06,936] ERROR [kafka-log-cleaner-thread-0]: Error due to > (kafka.log.LogCleaner:76) > java.lang.InterruptedException > at > java.base/java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedNanos(AbstractQueuedSynchronizer.java:1081) > at > java.base/java.util.concurrent.locks.AbstractQueuedSynchronizer.tryAcquireSharedNanos(AbstractQueuedSynchronizer.java:1369) > at > java.base/java.util.concurrent.CountDownLatch.await(CountDownLatch.java:278) > at kafka.utils.ShutdownableThread.pause(ShutdownableThread.scala:69) > at kafka.log.LogCleaner$CleanerThread.doWork(LogCleaner.scala:302) > at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:82) > [2019-04-23 01:20:06,940] ERROR [kafka-log-cleaner-thread-0]: Error due to > (kafka.log.LogCleaner:76) > java.lang.InterruptedException > at > java.base/java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedNanos(AbstractQueuedSynchronizer.java:1081) > at > java.base/java.util.concurrent.locks.AbstractQueuedSynchronizer.tryAcquireSharedNanos(AbstractQueuedSynchronizer.java:1369) > at > java.base/java.util.concurrent.CountDownLatch.await(CountDownLatch.java:278) > at kafka.utils.ShutdownableThread.pause(ShutdownableThread.scala:69) > at kafka.log.LogCleaner$CleanerThread.doWork(LogCleaner.scala:302) > at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:82) > {noformat} -- This message was sent by Atlassian Jira (v8.20.1#820001)