Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-8280

Flaky Test DynamicBrokerReconfigurationTest#testUncleanLeaderElectionEnable

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Open
    • Blocker
    • Resolution: Unresolved
    • 2.3.0
    • 4.0.0
    • None

    Description

      I saw this fail again on https://builds.apache.org/job/kafka-pr-jdk11-scala2.12/3979/testReport/junit/kafka.server/DynamicBrokerReconfigurationTest/testUncleanLeaderElectionEnable/

      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)
      
      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/localhost@EXAMPLE.COM tryFirstPass is false useFirstPass is false storePass is false clearPass is false
      principal is kafka/localhost@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/localhost@EXAMPLE.COM tryFirstPass is false useFirstPass is false storePass is false clearPass is false
      principal is kafka/localhost@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/localhost@EXAMPLE.COM tryFirstPass is false useFirstPass is false storePass is false clearPass is false
      principal is kafka/localhost@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 client@EXAMPLE.COM tryFirstPass is false useFirstPass is false storePass is false clearPass is false
      principal is client@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)
      
      

      Attachments

        Issue Links

          Activity

            People

              Unassigned Unassigned
              vvcephei John Roesler
              Votes:
              0 Vote for this issue
              Watchers:
              11 Start watching this issue

              Dates

                Created:
                Updated: