[ 
https://issues.apache.org/jira/browse/KAFKA-7541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Matthias J. Sax resolved KAFKA-7541.
------------------------------------
       Resolution: Duplicate
    Fix Version/s:     (was: 2.2.1)
                       (was: 2.3.0)

> Transient Failure: 
> kafka.server.DynamicBrokerReconfigurationTest.testUncleanLeaderElectionEnable
> ------------------------------------------------------------------------------------------------
>
>                 Key: KAFKA-7541
>                 URL: https://issues.apache.org/jira/browse/KAFKA-7541
>             Project: Kafka
>          Issue Type: Sub-task
>          Components: core, unit tests
>    Affects Versions: 2.2.0
>            Reporter: John Roesler
>            Priority: Critical
>              Labels: flaky-test
>
> Observed on Java 11: 
> [https://builds.apache.org/job/kafka-pr-jdk11-scala2.12/264/testReport/junit/kafka.server/DynamicBrokerReconfigurationTest/testUncleanLeaderElectionEnable/]
>  
> Stacktrace:
> {noformat}
> 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:487)
>       at 
> java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
>       at 
> java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
>       at 
> java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
>       at java.base/java.lang.reflect.Method.invoke(Method.java:566)
>       at 
> org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
>       at 
> org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
>       at 
> org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
>       at 
> org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
>       at 
> org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
>       at 
> org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
>       at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
>       at 
> org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
>       at 
> org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
>       at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
>       at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
>       at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
>       at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
>       at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
>       at 
> org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
>       at 
> org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
>       at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
>       at 
> org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecutor.runTestClass(JUnitTestClassExecutor.java:106)
>       at 
> org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecutor.execute(JUnitTestClassExecutor.java:58)
>       at 
> org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecutor.execute(JUnitTestClassExecutor.java:38)
>       at 
> org.gradle.api.internal.tasks.testing.junit.AbstractJUnitTestClassProcessor.processTestClass(AbstractJUnitTestClassProcessor.java:66)
>       at 
> org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:51)
>       at 
> java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
>       at 
> java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
>       at 
> java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
>       at java.base/java.lang.reflect.Method.invoke(Method.java:566)
>       at 
> org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
>       at 
> org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
>       at 
> org.gradle.internal.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
>       at 
> org.gradle.internal.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
>       at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
>       at 
> org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:117)
>       at 
> java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
>       at 
> java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
>       at 
> java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
>       at java.base/java.lang.reflect.Method.invoke(Method.java:566)
>       at 
> org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
>       at 
> org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
>       at 
> org.gradle.internal.remote.internal.hub.MessageHubBackedObjectConnection$DispatchWrapper.dispatch(MessageHubBackedObjectConnection.java:155)
>       at 
> org.gradle.internal.remote.internal.hub.MessageHubBackedObjectConnection$DispatchWrapper.dispatch(MessageHubBackedObjectConnection.java:137)
>       at 
> org.gradle.internal.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:404)
>       at 
> org.gradle.internal.concurrent.ExecutorPolicy$CatchAndRecordFailures.onExecute(ExecutorPolicy.java:63)
>       at 
> org.gradle.internal.concurrent.ManagedExecutorImpl$1.run(ManagedExecutorImpl.java:46)
>       at 
> java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
>       at 
> java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
>       at 
> org.gradle.internal.concurrent.ThreadFactoryImpl$ManagedThreadRunnable.run(ThreadFactoryImpl.java:55)
>       at java.base/java.lang.Thread.run(Thread.java:834){noformat}
>  
> Stdout:
> {noformat}
> Completed Updating config for entity: brokers '0'.
> Completed Updating config for entity: brokers '1'.
> Completed Updating config for entity: brokers '2'.
> Completed Updating config for entity: brokers '0'.
> Completed Updating config for entity: brokers '1'.
> Completed Updating config for entity: brokers '2'.
> [2018-10-24 20:36:08,709] ERROR [ReplicaFetcher replicaId=1, leaderId=2, 
> 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.
> [2018-10-24 20:36:08,717] ERROR [ReplicaFetcher replicaId=1, leaderId=2, 
> 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.
> [2018-10-24 20:36:08,717] ERROR [ReplicaFetcher replicaId=1, leaderId=2, 
> 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.
> [2018-10-24 20:36:08,718] ERROR [ReplicaFetcher replicaId=1, leaderId=2, 
> 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.
> [2018-10-24 20:36:08,718] ERROR [ReplicaFetcher replicaId=1, leaderId=2, 
> 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.
> [2018-10-24 20:36:08,719] ERROR [ReplicaFetcher replicaId=1, leaderId=2, 
> 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.
> [2018-10-24 20:36:08,719] ERROR [ReplicaFetcher replicaId=1, leaderId=2, 
> 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.
> [2018-10-24 20:36:08,720] ERROR [ReplicaFetcher replicaId=1, leaderId=2, 
> 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.
> [2018-10-24 20:36:08,761] ERROR [ReplicaFetcher replicaId=1, leaderId=0, 
> fetcherId=0] Error for partition __consumer_offsets-21 at offset 0 
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server 
> does not host this topic-partition.
> [2018-10-24 20:36:08,762] ERROR [ReplicaFetcher replicaId=1, leaderId=0, 
> fetcherId=0] Error for partition __consumer_offsets-27 at offset 0 
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server 
> does not host this topic-partition.
> [2018-10-24 20:36:08,763] ERROR [ReplicaFetcher replicaId=1, leaderId=0, 
> fetcherId=0] Error for partition __consumer_offsets-9 at offset 0 
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server 
> does not host this topic-partition.
> [2018-10-24 20:36:08,763] ERROR [ReplicaFetcher replicaId=1, leaderId=0, 
> fetcherId=0] Error for partition __consumer_offsets-33 at offset 0 
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server 
> does not host this topic-partition.
> [2018-10-24 20:36:08,763] ERROR [ReplicaFetcher replicaId=1, leaderId=0, 
> fetcherId=0] Error for partition __consumer_offsets-3 at offset 0 
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server 
> does not host this topic-partition.
> [2018-10-24 20:36:08,764] ERROR [ReplicaFetcher replicaId=1, leaderId=0, 
> fetcherId=0] Error for partition __consumer_offsets-15 at offset 0 
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server 
> does not host this topic-partition.
> [2018-10-24 20:36:08,766] ERROR [ReplicaFetcher replicaId=1, leaderId=0, 
> fetcherId=0] Error for partition __consumer_offsets-39 at offset 0 
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server 
> does not host this topic-partition.
> [2018-10-24 20:36:08,767] ERROR [ReplicaFetcher replicaId=1, leaderId=0, 
> fetcherId=0] Error for partition __consumer_offsets-45 at offset 0 
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server 
> does not host this topic-partition.
> [2018-10-24 20:36:08,785] ERROR [ReplicaFetcher replicaId=1, leaderId=0, 
> fetcherId=1] Error for partition __consumer_offsets-30 at offset 0 
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server 
> does not host this topic-partition.
> [2018-10-24 20:36:08,793] ERROR [ReplicaFetcher replicaId=1, leaderId=0, 
> fetcherId=1] Error for partition __consumer_offsets-36 at offset 0 
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server 
> does not host this topic-partition.
> [2018-10-24 20:36:08,795] ERROR [ReplicaFetcher replicaId=1, leaderId=0, 
> fetcherId=1] Error for partition __consumer_offsets-42 at offset 0 
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server 
> does not host this topic-partition.
> [2018-10-24 20:36:08,795] ERROR [ReplicaFetcher replicaId=1, leaderId=0, 
> fetcherId=1] Error for partition __consumer_offsets-18 at offset 0 
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server 
> does not host this topic-partition.
> [2018-10-24 20:36:08,796] ERROR [ReplicaFetcher replicaId=1, leaderId=0, 
> fetcherId=1] Error for partition __consumer_offsets-24 at offset 0 
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server 
> does not host this topic-partition.
> [2018-10-24 20:36:08,796] ERROR [ReplicaFetcher replicaId=1, leaderId=0, 
> fetcherId=1] Error for partition __consumer_offsets-48 at offset 0 
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server 
> does not host this topic-partition.
> [2018-10-24 20:36:08,796] ERROR [ReplicaFetcher replicaId=1, leaderId=0, 
> fetcherId=1] Error for partition __consumer_offsets-6 at offset 0 
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server 
> does not host this topic-partition.
> [2018-10-24 20:36:08,797] ERROR [ReplicaFetcher replicaId=1, leaderId=0, 
> fetcherId=1] Error for partition __consumer_offsets-0 at offset 0 
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server 
> does not host this topic-partition.
> [2018-10-24 20:36:08,797] ERROR [ReplicaFetcher replicaId=1, leaderId=0, 
> fetcherId=1] Error for partition __consumer_offsets-12 at offset 0 
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server 
> does not host this topic-partition.
> [2018-10-24 20:36:08,784] ERROR [ReplicaFetcher replicaId=2, leaderId=0, 
> fetcherId=1] Error for partition __consumer_offsets-30 at offset 0 
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server 
> does not host this topic-partition.
> [2018-10-24 20:36:08,803] ERROR [ReplicaFetcher replicaId=2, leaderId=0, 
> fetcherId=1] Error for partition __consumer_offsets-36 at offset 0 
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server 
> does not host this topic-partition.
> [2018-10-24 20:36:08,804] ERROR [ReplicaFetcher replicaId=2, leaderId=0, 
> fetcherId=1] Error for partition __consumer_offsets-42 at offset 0 
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server 
> does not host this topic-partition.
> [2018-10-24 20:36:08,804] ERROR [ReplicaFetcher replicaId=2, leaderId=0, 
> fetcherId=1] Error for partition __consumer_offsets-18 at offset 0 
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server 
> does not host this topic-partition.
> [2018-10-24 20:36:08,807] ERROR [ReplicaFetcher replicaId=2, leaderId=0, 
> fetcherId=1] Error for partition __consumer_offsets-24 at offset 0 
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server 
> does not host this topic-partition.
> [2018-10-24 20:36:08,808] ERROR [ReplicaFetcher replicaId=2, leaderId=0, 
> fetcherId=1] Error for partition __consumer_offsets-48 at offset 0 
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server 
> does not host this topic-partition.
> [2018-10-24 20:36:08,808] ERROR [ReplicaFetcher replicaId=2, leaderId=0, 
> fetcherId=1] Error for partition __consumer_offsets-6 at offset 0 
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server 
> does not host this topic-partition.
> [2018-10-24 20:36:08,809] ERROR [ReplicaFetcher replicaId=2, leaderId=0, 
> fetcherId=1] Error for partition __consumer_offsets-0 at offset 0 
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server 
> does not host this topic-partition.
> [2018-10-24 20:36:08,809] ERROR [ReplicaFetcher replicaId=2, leaderId=0, 
> fetcherId=1] Error for partition __consumer_offsets-12 at offset 0 
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server 
> does not host this topic-partition.
> [2018-10-24 20:36:08,782] ERROR [ReplicaFetcher replicaId=1, leaderId=2, 
> 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.
> [2018-10-24 20:36:08,811] ERROR [ReplicaFetcher replicaId=1, leaderId=2, 
> 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.
> [2018-10-24 20:36:08,812] ERROR [ReplicaFetcher replicaId=1, leaderId=2, 
> 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.
> [2018-10-24 20:36:08,812] ERROR [ReplicaFetcher replicaId=1, leaderId=2, 
> 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.
> [2018-10-24 20:36:08,812] ERROR [ReplicaFetcher replicaId=1, leaderId=2, 
> 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.
> [2018-10-24 20:36:08,813] ERROR [ReplicaFetcher replicaId=1, leaderId=2, 
> 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.
> [2018-10-24 20:36:08,813] ERROR [ReplicaFetcher replicaId=1, leaderId=2, 
> 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.
> [2018-10-24 20:36:08,814] ERROR [ReplicaFetcher replicaId=1, leaderId=2, 
> 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'.
> [2018-10-24 20:36:33,546] WARN Unable to reconnect to ZooKeeper service, 
> session 0x101d8c79a7c0002 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'.
> [2018-10-24 20:36:45,625] ERROR [ReplicaFetcher replicaId=0, 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.
> [2018-10-24 20:36:45,625] ERROR [ReplicaFetcher replicaId=0, 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.
> [2018-10-24 20:36:45,711] ERROR [ReplicaFetcher replicaId=0, 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.
> [2018-10-24 20:36:45,755] ERROR [ReplicaFetcher replicaId=0, 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.
> [2018-10-24 20:36:45,756] ERROR [ReplicaFetcher replicaId=0, 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.
> [2018-10-24 20:36:45,772] 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.
> [2018-10-24 20:36:45,773] 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.
> Completed Updating config for entity: brokers '0'.
> Completed Updating config for entity: brokers '1'.
> Completed Updating config for entity: brokers '2'.
> [2018-10-24 20:37:08,492] ERROR [ReplicaFetcher replicaId=0, 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.
> [2018-10-24 20:37:08,502] ERROR [ReplicaFetcher replicaId=0, 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.
> [2018-10-24 20:37:08,503] ERROR [ReplicaFetcher replicaId=0, 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.
> [2018-10-24 20:37:08,505] ERROR [ReplicaFetcher replicaId=0, 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.
> [2018-10-24 20:37:08,548] 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.
> [2018-10-24 20:37:08,549] 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.
> [2018-10-24 20:37:08,597] ERROR [ReplicaFetcher replicaId=0, leaderId=1, 
> 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.
> [2018-10-24 20:37:08,649] ERROR [ReplicaFetcher replicaId=2, leaderId=1, 
> 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.
> [2018-10-24 20:37:10,691] ERROR [ReplicaFetcher replicaId=0, leaderId=2, 
> fetcherId=0] Error for partition __consumer_offsets-21 at offset 0 
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server 
> does not host this topic-partition.
> [2018-10-24 20:37:10,692] ERROR [ReplicaFetcher replicaId=0, leaderId=2, 
> fetcherId=0] Error for partition __consumer_offsets-27 at offset 0 
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server 
> does not host this topic-partition.
> [2018-10-24 20:37:10,692] ERROR [ReplicaFetcher replicaId=0, leaderId=2, 
> fetcherId=0] Error for partition __consumer_offsets-9 at offset 0 
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server 
> does not host this topic-partition.
> [2018-10-24 20:37:10,693] ERROR [ReplicaFetcher replicaId=0, leaderId=2, 
> fetcherId=0] Error for partition __consumer_offsets-33 at offset 0 
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server 
> does not host this topic-partition.
> [2018-10-24 20:37:10,693] ERROR [ReplicaFetcher replicaId=0, leaderId=2, 
> fetcherId=0] Error for partition __consumer_offsets-3 at offset 0 
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server 
> does not host this topic-partition.
> [2018-10-24 20:37:10,693] ERROR [ReplicaFetcher replicaId=0, leaderId=2, 
> fetcherId=0] Error for partition __consumer_offsets-15 at offset 0 
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server 
> does not host this topic-partition.
> [2018-10-24 20:37:10,694] ERROR [ReplicaFetcher replicaId=0, leaderId=2, 
> fetcherId=0] Error for partition __consumer_offsets-39 at offset 0 
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server 
> does not host this topic-partition.
> [2018-10-24 20:37:10,694] ERROR [ReplicaFetcher replicaId=0, leaderId=2, 
> fetcherId=0] Error for partition __consumer_offsets-45 at offset 0 
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server 
> does not host this topic-partition.
> [2018-10-24 20:37:10,723] ERROR [ReplicaFetcher replicaId=1, leaderId=2, 
> fetcherId=0] Error for partition __consumer_offsets-21 at offset 0 
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server 
> does not host this topic-partition.
> [2018-10-24 20:37:10,724] ERROR [ReplicaFetcher replicaId=1, leaderId=2, 
> fetcherId=0] Error for partition __consumer_offsets-27 at offset 0 
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server 
> does not host this topic-partition.
> [2018-10-24 20:37:10,724] ERROR [ReplicaFetcher replicaId=1, leaderId=2, 
> fetcherId=0] Error for partition __consumer_offsets-9 at offset 0 
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server 
> does not host this topic-partition.
> [2018-10-24 20:37:10,725] ERROR [ReplicaFetcher replicaId=1, leaderId=2, 
> fetcherId=0] Error for partition __consumer_offsets-33 at offset 0 
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server 
> does not host this topic-partition.
> [2018-10-24 20:37:10,726] ERROR [ReplicaFetcher replicaId=1, leaderId=2, 
> fetcherId=0] Error for partition __consumer_offsets-3 at offset 0 
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server 
> does not host this topic-partition.
> [2018-10-24 20:37:10,726] ERROR [ReplicaFetcher replicaId=1, leaderId=2, 
> fetcherId=0] Error for partition __consumer_offsets-15 at offset 0 
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server 
> does not host this topic-partition.
> [2018-10-24 20:37:10,727] ERROR [ReplicaFetcher replicaId=1, leaderId=2, 
> fetcherId=0] Error for partition __consumer_offsets-39 at offset 0 
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server 
> does not host this topic-partition.
> [2018-10-24 20:37:10,727] ERROR [ReplicaFetcher replicaId=1, leaderId=2, 
> fetcherId=0] Error for partition __consumer_offsets-45 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'.
> [2018-10-24 20:37:16,025] WARN Unable to read additional data from client 
> sessionid 0x101d8c84cc50008, 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/kafka1107632288158235049.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/kafka1107632288158235049.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 
> [2018-10-24 20:37:31,431] ERROR [MetadataCache brokerId=0] Listeners are not 
> identical across brokers: Map(0 -> Map(ListenerName(EXTERNAL) -> 
> localhost:39015 (id: 0 rack: null), ListenerName(INTERNAL) -> localhost:34649 
> (id: 0 rack: null)), 2 -> Map(ListenerName(EXTERNAL) -> localhost:42229 (id: 
> 2 rack: null), ListenerName(INTERNAL) -> localhost:44290 (id: 2 rack: null)), 
> 1 -> Map(ListenerName(EXTERNAL) -> localhost:36175 (id: 1 rack: null), 
> ListenerName(INTERNAL) -> localhost:38889 (id: 1 rack: null), 
> ListenerName(SASL_PLAINTEXT) -> localhost:40079 (id: 1 rack: null))) 
> (kafka.server.MetadataCache:74)
> [2018-10-24 20:37:31,454] ERROR [MetadataCache brokerId=1] Listeners are not 
> identical across brokers: Map(0 -> Map(ListenerName(EXTERNAL) -> 
> localhost:39015 (id: 0 rack: null), ListenerName(INTERNAL) -> localhost:34649 
> (id: 0 rack: null)), 2 -> Map(ListenerName(EXTERNAL) -> localhost:42229 (id: 
> 2 rack: null), ListenerName(INTERNAL) -> localhost:44290 (id: 2 rack: null)), 
> 1 -> Map(ListenerName(EXTERNAL) -> localhost:36175 (id: 1 rack: null), 
> ListenerName(INTERNAL) -> localhost:38889 (id: 1 rack: null), 
> ListenerName(SASL_PLAINTEXT) -> localhost:40079 (id: 1 rack: null))) 
> (kafka.server.MetadataCache:74)
> [2018-10-24 20:37:31,455] ERROR [MetadataCache brokerId=2] Listeners are not 
> identical across brokers: Map(0 -> Map(ListenerName(EXTERNAL) -> 
> localhost:39015 (id: 0 rack: null), ListenerName(INTERNAL) -> localhost:34649 
> (id: 0 rack: null)), 2 -> Map(ListenerName(EXTERNAL) -> localhost:42229 (id: 
> 2 rack: null), ListenerName(INTERNAL) -> localhost:44290 (id: 2 rack: null)), 
> 1 -> Map(ListenerName(EXTERNAL) -> localhost:36175 (id: 1 rack: null), 
> ListenerName(INTERNAL) -> localhost:38889 (id: 1 rack: null), 
> ListenerName(SASL_PLAINTEXT) -> localhost:40079 (id: 1 rack: null))) 
> (kafka.server.MetadataCache:74)
> [2018-10-24 20:37:31,499] ERROR [MetadataCache brokerId=1] Listeners are not 
> identical across brokers: Map(0 -> Map(ListenerName(EXTERNAL) -> 
> localhost:39015 (id: 0 rack: null), ListenerName(INTERNAL) -> localhost:34649 
> (id: 0 rack: null)), 2 -> Map(ListenerName(EXTERNAL) -> localhost:42229 (id: 
> 2 rack: null), ListenerName(INTERNAL) -> localhost:44290 (id: 2 rack: null), 
> ListenerName(SASL_PLAINTEXT) -> localhost:34335 (id: 2 rack: null)), 1 -> 
> Map(ListenerName(EXTERNAL) -> localhost:36175 (id: 1 rack: null), 
> ListenerName(INTERNAL) -> localhost:38889 (id: 1 rack: null), 
> ListenerName(SASL_PLAINTEXT) -> localhost:40079 (id: 1 rack: null))) 
> (kafka.server.MetadataCache:74)
> [2018-10-24 20:37:31,499] ERROR [MetadataCache brokerId=0] Listeners are not 
> identical across brokers: Map(0 -> Map(ListenerName(EXTERNAL) -> 
> localhost:39015 (id: 0 rack: null), ListenerName(INTERNAL) -> localhost:34649 
> (id: 0 rack: null)), 2 -> Map(ListenerName(EXTERNAL) -> localhost:42229 (id: 
> 2 rack: null), ListenerName(INTERNAL) -> localhost:44290 (id: 2 rack: null), 
> ListenerName(SASL_PLAINTEXT) -> localhost:34335 (id: 2 rack: null)), 1 -> 
> Map(ListenerName(EXTERNAL) -> localhost:36175 (id: 1 rack: null), 
> ListenerName(INTERNAL) -> localhost:38889 (id: 1 rack: null), 
> ListenerName(SASL_PLAINTEXT) -> localhost:40079 (id: 1 rack: null))) 
> (kafka.server.MetadataCache:74)
> [2018-10-24 20:37:31,501] ERROR [MetadataCache brokerId=2] Listeners are not 
> identical across brokers: Map(0 -> Map(ListenerName(EXTERNAL) -> 
> localhost:39015 (id: 0 rack: null), ListenerName(INTERNAL) -> localhost:34649 
> (id: 0 rack: null)), 2 -> Map(ListenerName(EXTERNAL) -> localhost:42229 (id: 
> 2 rack: null), ListenerName(INTERNAL) -> localhost:44290 (id: 2 rack: null), 
> ListenerName(SASL_PLAINTEXT) -> localhost:34335 (id: 2 rack: null)), 1 -> 
> Map(ListenerName(EXTERNAL) -> localhost:36175 (id: 1 rack: null), 
> ListenerName(INTERNAL) -> localhost:38889 (id: 1 rack: null), 
> ListenerName(SASL_PLAINTEXT) -> localhost:40079 (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/kafka12991092865355940476.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 
> [2018-10-24 20:37:34,942] ERROR [MetadataCache brokerId=2] Listeners are not 
> identical across brokers: Map(0 -> Map(ListenerName(EXTERNAL) -> 
> localhost:39015 (id: 0 rack: null), ListenerName(INTERNAL) -> localhost:34649 
> (id: 0 rack: null), ListenerName(SASL_PLAINTEXT) -> localhost:35548 (id: 0 
> rack: null)), 2 -> Map(ListenerName(EXTERNAL) -> localhost:42229 (id: 2 rack: 
> null), ListenerName(INTERNAL) -> localhost:44290 (id: 2 rack: null)), 1 -> 
> Map(ListenerName(EXTERNAL) -> localhost:36175 (id: 1 rack: null), 
> ListenerName(INTERNAL) -> localhost:38889 (id: 1 rack: null), 
> ListenerName(SASL_PLAINTEXT) -> localhost:40079 (id: 1 rack: null))) 
> (kafka.server.MetadataCache:74)
> [2018-10-24 20:37:34,974] ERROR [MetadataCache brokerId=1] Listeners are not 
> identical across brokers: Map(0 -> Map(ListenerName(EXTERNAL) -> 
> localhost:39015 (id: 0 rack: null), ListenerName(INTERNAL) -> localhost:34649 
> (id: 0 rack: null), ListenerName(SASL_PLAINTEXT) -> localhost:35548 (id: 0 
> rack: null)), 2 -> Map(ListenerName(EXTERNAL) -> localhost:42229 (id: 2 rack: 
> null), ListenerName(INTERNAL) -> localhost:44290 (id: 2 rack: null)), 1 -> 
> Map(ListenerName(EXTERNAL) -> localhost:36175 (id: 1 rack: null), 
> ListenerName(INTERNAL) -> localhost:38889 (id: 1 rack: null), 
> ListenerName(SASL_PLAINTEXT) -> localhost:40079 (id: 1 rack: null))) 
> (kafka.server.MetadataCache:74)
> [2018-10-24 20:37:34,995] ERROR [MetadataCache brokerId=0] Listeners are not 
> identical across brokers: Map(0 -> Map(ListenerName(EXTERNAL) -> 
> localhost:39015 (id: 0 rack: null), ListenerName(INTERNAL) -> localhost:34649 
> (id: 0 rack: null), ListenerName(SASL_PLAINTEXT) -> localhost:35548 (id: 0 
> rack: null)), 2 -> Map(ListenerName(EXTERNAL) -> localhost:42229 (id: 2 rack: 
> null), ListenerName(INTERNAL) -> localhost:44290 (id: 2 rack: null)), 1 -> 
> Map(ListenerName(EXTERNAL) -> localhost:36175 (id: 1 rack: null), 
> ListenerName(INTERNAL) -> localhost:38889 (id: 1 rack: null), 
> ListenerName(SASL_PLAINTEXT) -> localhost:40079 (id: 1 rack: null))) 
> (kafka.server.MetadataCache:74)
> [2018-10-24 20:37:35,015] ERROR [MetadataCache brokerId=2] Listeners are not 
> identical across brokers: Map(0 -> Map(ListenerName(EXTERNAL) -> 
> localhost:39015 (id: 0 rack: null), ListenerName(INTERNAL) -> localhost:34649 
> (id: 0 rack: null)), 2 -> Map(ListenerName(EXTERNAL) -> localhost:42229 (id: 
> 2 rack: null), ListenerName(INTERNAL) -> localhost:44290 (id: 2 rack: null)), 
> 1 -> Map(ListenerName(EXTERNAL) -> localhost:36175 (id: 1 rack: null), 
> ListenerName(INTERNAL) -> localhost:38889 (id: 1 rack: null), 
> ListenerName(SASL_PLAINTEXT) -> localhost:40079 (id: 1 rack: null))) 
> (kafka.server.MetadataCache:74)
> [2018-10-24 20:37:35,014] ERROR [MetadataCache brokerId=1] Listeners are not 
> identical across brokers: Map(0 -> Map(ListenerName(EXTERNAL) -> 
> localhost:39015 (id: 0 rack: null), ListenerName(INTERNAL) -> localhost:34649 
> (id: 0 rack: null)), 2 -> Map(ListenerName(EXTERNAL) -> localhost:42229 (id: 
> 2 rack: null), ListenerName(INTERNAL) -> localhost:44290 (id: 2 rack: null)), 
> 1 -> Map(ListenerName(EXTERNAL) -> localhost:36175 (id: 1 rack: null), 
> ListenerName(INTERNAL) -> localhost:38889 (id: 1 rack: null), 
> ListenerName(SASL_PLAINTEXT) -> localhost:40079 (id: 1 rack: null))) 
> (kafka.server.MetadataCache:74)
> [2018-10-24 20:37:35,059] ERROR [MetadataCache brokerId=0] Listeners are not 
> identical across brokers: Map(0 -> Map(ListenerName(EXTERNAL) -> 
> localhost:39015 (id: 0 rack: null), ListenerName(INTERNAL) -> localhost:34649 
> (id: 0 rack: null)), 2 -> Map(ListenerName(EXTERNAL) -> localhost:42229 (id: 
> 2 rack: null), ListenerName(INTERNAL) -> localhost:44290 (id: 2 rack: null)), 
> 1 -> Map(ListenerName(EXTERNAL) -> localhost:36175 (id: 1 rack: null), 
> ListenerName(INTERNAL) -> localhost:38889 (id: 1 rack: null), 
> ListenerName(SASL_PLAINTEXT) -> localhost:40079 (id: 1 rack: null))) 
> (kafka.server.MetadataCache:74)
> [2018-10-24 20:37:39,292] ERROR [MetadataCache brokerId=0] Listeners are not 
> identical across brokers: Map(0 -> Map(ListenerName(EXTERNAL) -> 
> localhost:39015 (id: 0 rack: null), ListenerName(INTERNAL) -> localhost:34649 
> (id: 0 rack: null)), 2 -> Map(ListenerName(EXTERNAL) -> localhost:42229 (id: 
> 2 rack: null), ListenerName(INTERNAL) -> localhost:44290 (id: 2 rack: null), 
> ListenerName(SCRAM_LISTENER) -> localhost:46677 (id: 2 rack: null)), 1 -> 
> Map(ListenerName(EXTERNAL) -> localhost:36175 (id: 1 rack: null), 
> ListenerName(INTERNAL) -> localhost:38889 (id: 1 rack: null))) 
> (kafka.server.MetadataCache:74)
> [2018-10-24 20:37:39,293] ERROR [MetadataCache brokerId=2] Listeners are not 
> identical across brokers: Map(0 -> Map(ListenerName(EXTERNAL) -> 
> localhost:39015 (id: 0 rack: null), ListenerName(INTERNAL) -> localhost:34649 
> (id: 0 rack: null)), 2 -> Map(ListenerName(EXTERNAL) -> localhost:42229 (id: 
> 2 rack: null), ListenerName(INTERNAL) -> localhost:44290 (id: 2 rack: null), 
> ListenerName(SCRAM_LISTENER) -> localhost:46677 (id: 2 rack: null)), 1 -> 
> Map(ListenerName(EXTERNAL) -> localhost:36175 (id: 1 rack: null), 
> ListenerName(INTERNAL) -> localhost:38889 (id: 1 rack: null))) 
> (kafka.server.MetadataCache:74)
> [2018-10-24 20:37:39,293] ERROR [MetadataCache brokerId=1] Listeners are not 
> identical across brokers: Map(0 -> Map(ListenerName(EXTERNAL) -> 
> localhost:39015 (id: 0 rack: null), ListenerName(INTERNAL) -> localhost:34649 
> (id: 0 rack: null)), 2 -> Map(ListenerName(EXTERNAL) -> localhost:42229 (id: 
> 2 rack: null), ListenerName(INTERNAL) -> localhost:44290 (id: 2 rack: null), 
> ListenerName(SCRAM_LISTENER) -> localhost:46677 (id: 2 rack: null)), 1 -> 
> Map(ListenerName(EXTERNAL) -> localhost:36175 (id: 1 rack: null), 
> ListenerName(INTERNAL) -> localhost:38889 (id: 1 rack: null))) 
> (kafka.server.MetadataCache:74)
> [2018-10-24 20:37:39,338] ERROR [MetadataCache brokerId=2] Listeners are not 
> identical across brokers: Map(0 -> Map(ListenerName(EXTERNAL) -> 
> localhost:39015 (id: 0 rack: null), ListenerName(INTERNAL) -> localhost:34649 
> (id: 0 rack: null)), 2 -> Map(ListenerName(EXTERNAL) -> localhost:42229 (id: 
> 2 rack: null), ListenerName(INTERNAL) -> localhost:44290 (id: 2 rack: null), 
> ListenerName(SCRAM_LISTENER) -> localhost:46677 (id: 2 rack: null)), 1 -> 
> Map(ListenerName(EXTERNAL) -> localhost:36175 (id: 1 rack: null), 
> ListenerName(INTERNAL) -> localhost:38889 (id: 1 rack: null), 
> ListenerName(SCRAM_LISTENER) -> localhost:38748 (id: 1 rack: null))) 
> (kafka.server.MetadataCache:74)
> [2018-10-24 20:37:39,357] ERROR [MetadataCache brokerId=1] Listeners are not 
> identical across brokers: Map(0 -> Map(ListenerName(EXTERNAL) -> 
> localhost:39015 (id: 0 rack: null), ListenerName(INTERNAL) -> localhost:34649 
> (id: 0 rack: null)), 2 -> Map(ListenerName(EXTERNAL) -> localhost:42229 (id: 
> 2 rack: null), ListenerName(INTERNAL) -> localhost:44290 (id: 2 rack: null), 
> ListenerName(SCRAM_LISTENER) -> localhost:46677 (id: 2 rack: null)), 1 -> 
> Map(ListenerName(EXTERNAL) -> localhost:36175 (id: 1 rack: null), 
> ListenerName(INTERNAL) -> localhost:38889 (id: 1 rack: null), 
> ListenerName(SCRAM_LISTENER) -> localhost:38748 (id: 1 rack: null))) 
> (kafka.server.MetadataCache:74)
> [2018-10-24 20:37:39,356] ERROR [MetadataCache brokerId=0] Listeners are not 
> identical across brokers: Map(0 -> Map(ListenerName(EXTERNAL) -> 
> localhost:39015 (id: 0 rack: null), ListenerName(INTERNAL) -> localhost:34649 
> (id: 0 rack: null)), 2 -> Map(ListenerName(EXTERNAL) -> localhost:42229 (id: 
> 2 rack: null), ListenerName(INTERNAL) -> localhost:44290 (id: 2 rack: null), 
> ListenerName(SCRAM_LISTENER) -> localhost:46677 (id: 2 rack: null)), 1 -> 
> Map(ListenerName(EXTERNAL) -> localhost:36175 (id: 1 rack: null), 
> ListenerName(INTERNAL) -> localhost:38889 (id: 1 rack: null), 
> ListenerName(SCRAM_LISTENER) -> localhost:38748 (id: 1 rack: null))) 
> (kafka.server.MetadataCache:74)
> [2018-10-24 20:37:40,016] ERROR [MetadataCache brokerId=0] Listeners are not 
> identical across brokers: Map(0 -> Map(ListenerName(EXTERNAL) -> 
> localhost:39015 (id: 0 rack: null), ListenerName(INTERNAL) -> localhost:34649 
> (id: 0 rack: null)), 2 -> Map(ListenerName(EXTERNAL) -> localhost:42229 (id: 
> 2 rack: null), ListenerName(INTERNAL) -> localhost:44290 (id: 2 rack: null), 
> ListenerName(SCRAM_LISTENER) -> localhost:46677 (id: 2 rack: null)), 1 -> 
> Map(ListenerName(EXTERNAL) -> localhost:36175 (id: 1 rack: null), 
> ListenerName(INTERNAL) -> localhost:38889 (id: 1 rack: null), 
> ListenerName(SCRAM_LISTENER) -> localhost:38748 (id: 1 rack: null))) 
> (kafka.server.MetadataCache:74)
> [2018-10-24 20:37:40,038] ERROR [MetadataCache brokerId=1] Listeners are not 
> identical across brokers: Map(0 -> Map(ListenerName(EXTERNAL) -> 
> localhost:39015 (id: 0 rack: null), ListenerName(INTERNAL) -> localhost:34649 
> (id: 0 rack: null)), 2 -> Map(ListenerName(EXTERNAL) -> localhost:42229 (id: 
> 2 rack: null), ListenerName(INTERNAL) -> localhost:44290 (id: 2 rack: null), 
> ListenerName(SCRAM_LISTENER) -> localhost:46677 (id: 2 rack: null)), 1 -> 
> Map(ListenerName(EXTERNAL) -> localhost:36175 (id: 1 rack: null), 
> ListenerName(INTERNAL) -> localhost:38889 (id: 1 rack: null), 
> ListenerName(SCRAM_LISTENER) -> localhost:38748 (id: 1 rack: null))) 
> (kafka.server.MetadataCache:74)
> [2018-10-24 20:37:40,054] ERROR [MetadataCache brokerId=2] Listeners are not 
> identical across brokers: Map(0 -> Map(ListenerName(EXTERNAL) -> 
> localhost:39015 (id: 0 rack: null), ListenerName(INTERNAL) -> localhost:34649 
> (id: 0 rack: null)), 2 -> Map(ListenerName(EXTERNAL) -> localhost:42229 (id: 
> 2 rack: null), ListenerName(INTERNAL) -> localhost:44290 (id: 2 rack: null), 
> ListenerName(SCRAM_LISTENER) -> localhost:46677 (id: 2 rack: null)), 1 -> 
> Map(ListenerName(EXTERNAL) -> localhost:36175 (id: 1 rack: null), 
> ListenerName(INTERNAL) -> localhost:38889 (id: 1 rack: null), 
> ListenerName(SCRAM_LISTENER) -> localhost:38748 (id: 1 rack: null))) 
> (kafka.server.MetadataCache:74)
> [2018-10-24 20:37:40,220] ERROR [MetadataCache brokerId=1] Listeners are not 
> identical across brokers: Map(0 -> Map(ListenerName(EXTERNAL) -> 
> localhost:39015 (id: 0 rack: null), ListenerName(INTERNAL) -> localhost:34649 
> (id: 0 rack: null)), 2 -> Map(ListenerName(EXTERNAL) -> localhost:42229 (id: 
> 2 rack: null), ListenerName(INTERNAL) -> localhost:44290 (id: 2 rack: null), 
> ListenerName(SCRAM_LISTENER) -> localhost:46677 (id: 2 rack: null)), 1 -> 
> Map(ListenerName(EXTERNAL) -> localhost:36175 (id: 1 rack: null), 
> ListenerName(INTERNAL) -> localhost:38889 (id: 1 rack: null), 
> ListenerName(SCRAM_LISTENER) -> localhost:38748 (id: 1 rack: null))) 
> (kafka.server.MetadataCache:74)
> [2018-10-24 20:37:40,251] ERROR [MetadataCache brokerId=2] Listeners are not 
> identical across brokers: Map(0 -> Map(ListenerName(EXTERNAL) -> 
> localhost:39015 (id: 0 rack: null), ListenerName(INTERNAL) -> localhost:34649 
> (id: 0 rack: null)), 2 -> Map(ListenerName(EXTERNAL) -> localhost:42229 (id: 
> 2 rack: null), ListenerName(INTERNAL) -> localhost:44290 (id: 2 rack: null), 
> ListenerName(SCRAM_LISTENER) -> localhost:46677 (id: 2 rack: null)), 1 -> 
> Map(ListenerName(EXTERNAL) -> localhost:36175 (id: 1 rack: null), 
> ListenerName(INTERNAL) -> localhost:38889 (id: 1 rack: null), 
> ListenerName(SCRAM_LISTENER) -> localhost:38748 (id: 1 rack: null))) 
> (kafka.server.MetadataCache:74)
> [2018-10-24 20:37:40,265] ERROR [MetadataCache brokerId=2] Listeners are not 
> identical across brokers: Map(0 -> Map(ListenerName(EXTERNAL) -> 
> localhost:39015 (id: 0 rack: null), ListenerName(INTERNAL) -> localhost:34649 
> (id: 0 rack: null)), 2 -> Map(ListenerName(EXTERNAL) -> localhost:42229 (id: 
> 2 rack: null), ListenerName(INTERNAL) -> localhost:44290 (id: 2 rack: null), 
> ListenerName(SCRAM_LISTENER) -> localhost:46677 (id: 2 rack: null)), 1 -> 
> Map(ListenerName(EXTERNAL) -> localhost:36175 (id: 1 rack: null), 
> ListenerName(INTERNAL) -> localhost:38889 (id: 1 rack: null), 
> ListenerName(SCRAM_LISTENER) -> localhost:38748 (id: 1 rack: null))) 
> (kafka.server.MetadataCache:74)
> [2018-10-24 20:37:40,283] ERROR [MetadataCache brokerId=1] Listeners are not 
> identical across brokers: Map(0 -> Map(ListenerName(EXTERNAL) -> 
> localhost:39015 (id: 0 rack: null), ListenerName(INTERNAL) -> localhost:34649 
> (id: 0 rack: null)), 2 -> Map(ListenerName(EXTERNAL) -> localhost:42229 (id: 
> 2 rack: null), ListenerName(INTERNAL) -> localhost:44290 (id: 2 rack: null), 
> ListenerName(SCRAM_LISTENER) -> localhost:46677 (id: 2 rack: null)), 1 -> 
> Map(ListenerName(EXTERNAL) -> localhost:36175 (id: 1 rack: null), 
> ListenerName(INTERNAL) -> localhost:38889 (id: 1 rack: null), 
> ListenerName(SCRAM_LISTENER) -> localhost:38748 (id: 1 rack: null))) 
> (kafka.server.MetadataCache:74)
> [2018-10-24 20:37:40,348] ERROR [MetadataCache brokerId=2] Listeners are not 
> identical across brokers: Map(0 -> Map(ListenerName(EXTERNAL) -> 
> localhost:39015 (id: 0 rack: null), ListenerName(INTERNAL) -> localhost:34649 
> (id: 0 rack: null)), 2 -> Map(ListenerName(EXTERNAL) -> localhost:42229 (id: 
> 2 rack: null), ListenerName(INTERNAL) -> localhost:44290 (id: 2 rack: null), 
> ListenerName(SCRAM_LISTENER) -> localhost:46677 (id: 2 rack: null)), 1 -> 
> Map(ListenerName(EXTERNAL) -> localhost:36175 (id: 1 rack: null), 
> ListenerName(INTERNAL) -> localhost:38889 (id: 1 rack: null), 
> ListenerName(SCRAM_LISTENER) -> localhost:38748 (id: 1 rack: null))) 
> (kafka.server.MetadataCache:74)
> [2018-10-24 20:37:40,348] ERROR [MetadataCache brokerId=1] Listeners are not 
> identical across brokers: Map(0 -> Map(ListenerName(EXTERNAL) -> 
> localhost:39015 (id: 0 rack: null), ListenerName(INTERNAL) -> localhost:34649 
> (id: 0 rack: null)), 2 -> Map(ListenerName(EXTERNAL) -> localhost:42229 (id: 
> 2 rack: null), ListenerName(INTERNAL) -> localhost:44290 (id: 2 rack: null), 
> ListenerName(SCRAM_LISTENER) -> localhost:46677 (id: 2 rack: null)), 1 -> 
> Map(ListenerName(EXTERNAL) -> localhost:36175 (id: 1 rack: null), 
> ListenerName(INTERNAL) -> localhost:38889 (id: 1 rack: null), 
> ListenerName(SCRAM_LISTENER) -> localhost:38748 (id: 1 rack: null))) 
> (kafka.server.MetadataCache:74)
> Completed Updating config for entity: brokers '0'.
> Completed Updating config for entity: brokers '1'.
> Completed Updating config for entity: brokers '2'.
> [2018-10-24 20:37:47,823] ERROR [ReplicaFetcher replicaId=1, 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.
> [2018-10-24 20:37:47,856] ERROR [ReplicaFetcher replicaId=1, 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.
> [2018-10-24 20:37:47,971] 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.
> [2018-10-24 20:37:48,009] 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.
> [2018-10-24 20:37:49,995] ERROR [ReplicaFetcher replicaId=1, leaderId=0, 
> fetcherId=0] Error for partition __consumer_offsets-21 at offset 0 
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server 
> does not host this topic-partition.
> [2018-10-24 20:37:49,996] ERROR [ReplicaFetcher replicaId=1, leaderId=0, 
> fetcherId=0] Error for partition __consumer_offsets-27 at offset 0 
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server 
> does not host this topic-partition.
> [2018-10-24 20:37:49,996] ERROR [ReplicaFetcher replicaId=1, leaderId=0, 
> fetcherId=0] Error for partition __consumer_offsets-9 at offset 0 
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server 
> does not host this topic-partition.
> [2018-10-24 20:37:49,997] ERROR [ReplicaFetcher replicaId=1, leaderId=0, 
> fetcherId=0] Error for partition __consumer_offsets-33 at offset 0 
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server 
> does not host this topic-partition.
> [2018-10-24 20:37:49,997] ERROR [ReplicaFetcher replicaId=1, leaderId=0, 
> fetcherId=0] Error for partition __consumer_offsets-3 at offset 0 
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server 
> does not host this topic-partition.
> [2018-10-24 20:37:49,997] ERROR [ReplicaFetcher replicaId=1, leaderId=0, 
> fetcherId=0] Error for partition __consumer_offsets-15 at offset 0 
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server 
> does not host this topic-partition.
> [2018-10-24 20:37:49,997] ERROR [ReplicaFetcher replicaId=1, leaderId=0, 
> fetcherId=0] Error for partition __consumer_offsets-39 at offset 0 
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server 
> does not host this topic-partition.
> [2018-10-24 20:37:49,998] ERROR [ReplicaFetcher replicaId=1, leaderId=0, 
> fetcherId=0] Error for partition __consumer_offsets-45 at offset 0 
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server 
> does not host this topic-partition.
> [2018-10-24 20:37:50,019] ERROR [ReplicaFetcher replicaId=1, leaderId=2, 
> 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.
> [2018-10-24 20:37:50,020] ERROR [ReplicaFetcher replicaId=1, leaderId=2, 
> 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.
> [2018-10-24 20:37:50,021] ERROR [ReplicaFetcher replicaId=1, leaderId=2, 
> 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.
> [2018-10-24 20:37:50,021] ERROR [ReplicaFetcher replicaId=1, leaderId=2, 
> 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.
> [2018-10-24 20:37:50,021] ERROR [ReplicaFetcher replicaId=1, leaderId=2, 
> 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.
> [2018-10-24 20:37:50,022] ERROR [ReplicaFetcher replicaId=1, leaderId=2, 
> 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.
> [2018-10-24 20:37:50,022] ERROR [ReplicaFetcher replicaId=1, leaderId=2, 
> 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.
> [2018-10-24 20:37:50,022] ERROR [ReplicaFetcher replicaId=1, leaderId=2, 
> 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.
> [2018-10-24 20:37:50,031] ERROR [ReplicaFetcher replicaId=1, leaderId=2, 
> 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.
> [2018-10-24 20:37:50,032] ERROR [ReplicaFetcher replicaId=1, leaderId=2, 
> 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.
> [2018-10-24 20:37:50,032] ERROR [ReplicaFetcher replicaId=1, leaderId=2, 
> 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.
> [2018-10-24 20:37:50,033] ERROR [ReplicaFetcher replicaId=1, leaderId=2, 
> 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.
> [2018-10-24 20:37:50,033] ERROR [ReplicaFetcher replicaId=1, leaderId=2, 
> 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.
> [2018-10-24 20:37:50,033] ERROR [ReplicaFetcher replicaId=1, leaderId=2, 
> 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.
> [2018-10-24 20:37:50,034] ERROR [ReplicaFetcher replicaId=1, leaderId=2, 
> 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.
> [2018-10-24 20:37:50,034] ERROR [ReplicaFetcher replicaId=1, leaderId=2, 
> 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.
> [2018-10-24 20:37:54,989] ERROR [Producer clientId=test-client] Connection to 
> node -1 (localhost/127.0.0.1:43584) failed authentication due to: SSL 
> handshake failed (org.apache.kafka.clients.NetworkClient:677)
> [2018-10-24 20:37:55,018] ERROR [Producer clientId=test-client] Connection to 
> node -2 (localhost/127.0.0.1:42400) failed authentication due to: SSL 
> handshake failed (org.apache.kafka.clients.NetworkClient:677)
> [2018-10-24 20:37:55,020] ERROR [Producer clientId=test-client] Connection to 
> node -3 (localhost/127.0.0.1:43888) failed authentication due to: SSL 
> handshake failed (org.apache.kafka.clients.NetworkClient:677)
> [2018-10-24 20:37:55,448] ERROR [Producer clientId=test-client] Connection to 
> node -1 (localhost/127.0.0.1:43584) failed authentication due to: SSL 
> handshake failed (org.apache.kafka.clients.NetworkClient:677)
> [2018-10-24 20:37:55,449] ERROR [Producer clientId=test-client] Connection to 
> node -2 (localhost/127.0.0.1:42400) failed authentication due to: SSL 
> handshake failed (org.apache.kafka.clients.NetworkClient:677)
> [2018-10-24 20:37:55,449] ERROR [Producer clientId=test-client] Connection to 
> node -3 (localhost/127.0.0.1:43888) failed authentication due to: SSL 
> handshake failed (org.apache.kafka.clients.NetworkClient:677)
> [2018-10-24 20:37:55,945] ERROR [Producer clientId=test-client] Connection to 
> node -3 (localhost/127.0.0.1:43888) failed authentication due to: SSL 
> handshake failed (org.apache.kafka.clients.NetworkClient:677)
> [2018-10-24 20:37:55,954] ERROR [Producer clientId=test-client] Connection to 
> node -1 (localhost/127.0.0.1:43584) failed authentication due to: SSL 
> handshake failed (org.apache.kafka.clients.NetworkClient:677)
> [2018-10-24 20:37:56,089] ERROR [Producer clientId=test-client] Connection to 
> node -2 (localhost/127.0.0.1:42400) failed authentication due to: SSL 
> handshake failed (org.apache.kafka.clients.NetworkClient:677)
> [2018-10-24 20:37:57,123] ERROR [Producer clientId=test-client] Connection to 
> node -2 (localhost/127.0.0.1:42400) failed authentication due to: SSL 
> handshake failed (org.apache.kafka.clients.NetworkClient:677)
> [2018-10-24 20:38:02,879] ERROR [Producer clientId=test-client] Connection to 
> node -1 (localhost/127.0.0.1:43584) failed authentication due to: SSL 
> handshake failed (org.apache.kafka.clients.NetworkClient:677)
> [2018-10-24 20:38:02,936] ERROR [Producer clientId=test-client] Connection to 
> node -2 (localhost/127.0.0.1:42400) failed authentication due to: SSL 
> handshake failed (org.apache.kafka.clients.NetworkClient:677)
> [2018-10-24 20:38:03,077] ERROR [Producer clientId=test-client] Connection to 
> node -3 (localhost/127.0.0.1:43888) failed authentication due to: SSL 
> handshake failed (org.apache.kafka.clients.NetworkClient:677)
> [2018-10-24 20:38:03,107] ERROR [Producer clientId=test-client] Connection to 
> node -2 (localhost/127.0.0.1:42400) failed authentication due to: SSL 
> handshake failed (org.apache.kafka.clients.NetworkClient:677)
> [2018-10-24 20:38:03,270] ERROR [Producer clientId=test-client] Connection to 
> node -3 (localhost/127.0.0.1:43888) failed authentication due to: SSL 
> handshake failed (org.apache.kafka.clients.NetworkClient:677)
> [2018-10-24 20:38:03,272] ERROR [Producer clientId=test-client] Connection to 
> node -1 (localhost/127.0.0.1:43584) failed authentication due to: SSL 
> handshake failed (org.apache.kafka.clients.NetworkClient:677)
> [2018-10-24 20:38:03,605] ERROR [Producer clientId=test-client] Connection to 
> node -2 (localhost/127.0.0.1:42400) failed authentication due to: SSL 
> handshake failed (org.apache.kafka.clients.NetworkClient:677)
> [2018-10-24 20:38:03,729] ERROR [Producer clientId=test-client] Connection to 
> node -1 (localhost/127.0.0.1:43584) failed authentication due to: SSL 
> handshake failed (org.apache.kafka.clients.NetworkClient:677)
> [2018-10-24 20:38:03,906] ERROR [Producer clientId=test-client] Connection to 
> node -3 (localhost/127.0.0.1:43888) failed authentication due to: SSL 
> handshake failed (org.apache.kafka.clients.NetworkClient:677)
> [2018-10-24 20:38:07,834] WARN Unable to read additional data from client 
> sessionid 0x101d8c8e9a40006, 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'.
> Completed Updating config for entity: brokers '0'.
> Completed Updating config for entity: brokers '1'.
> Completed Updating config for entity: brokers '2'.
> [2018-10-24 20:38:44,038] 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.
> [2018-10-24 20:38:44,059] 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.
> [2018-10-24 20:38:44,059] 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.
> [2018-10-24 20:38:44,064] 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.
> [2018-10-24 20:38:44,063] 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.
> [2018-10-24 20:38:44,062] 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.
> [2018-10-24 20:38:44,060] 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.
> [2018-10-24 20:38:44,074] 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.
> [2018-10-24 20:38:46,108] ERROR [ReplicaFetcher replicaId=2, leaderId=1, 
> fetcherId=0] Error for partition __consumer_offsets-21 at offset 0 
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server 
> does not host this topic-partition.
> [2018-10-24 20:38:46,108] ERROR [ReplicaFetcher replicaId=2, leaderId=1, 
> fetcherId=0] Error for partition __consumer_offsets-27 at offset 0 
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server 
> does not host this topic-partition.
> [2018-10-24 20:38:46,109] ERROR [ReplicaFetcher replicaId=2, leaderId=1, 
> fetcherId=0] Error for partition __consumer_offsets-9 at offset 0 
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server 
> does not host this topic-partition.
> [2018-10-24 20:38:46,109] ERROR [ReplicaFetcher replicaId=2, leaderId=1, 
> fetcherId=0] Error for partition __consumer_offsets-33 at offset 0 
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server 
> does not host this topic-partition.
> [2018-10-24 20:38:46,109] ERROR [ReplicaFetcher replicaId=2, leaderId=1, 
> fetcherId=0] Error for partition __consumer_offsets-3 at offset 0 
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server 
> does not host this topic-partition.
> [2018-10-24 20:38:46,109] ERROR [ReplicaFetcher replicaId=2, leaderId=1, 
> fetcherId=0] Error for partition __consumer_offsets-15 at offset 0 
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server 
> does not host this topic-partition.
> [2018-10-24 20:38:46,110] ERROR [ReplicaFetcher replicaId=2, leaderId=1, 
> fetcherId=0] Error for partition __consumer_offsets-39 at offset 0 
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server 
> does not host this topic-partition.
> [2018-10-24 20:38:46,110] ERROR [ReplicaFetcher replicaId=2, leaderId=1, 
> fetcherId=0] Error for partition __consumer_offsets-45 at offset 0 
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server 
> does not host this topic-partition.
> [2018-10-24 20:38:52,355] ERROR [Producer clientId=test-client] Connection to 
> node -3 (localhost/127.0.0.1:45909) failed authentication due to: SSL 
> handshake failed (org.apache.kafka.clients.NetworkClient:677)
> [2018-10-24 20:38:52,356] ERROR [Producer clientId=test-client] Connection to 
> node -1 (localhost/127.0.0.1:33492) failed authentication due to: SSL 
> handshake failed (org.apache.kafka.clients.NetworkClient:677)
> [2018-10-24 20:38:52,486] ERROR [Producer clientId=test-client] Connection to 
> node -2 (localhost/127.0.0.1:32921) failed authentication due to: SSL 
> handshake failed (org.apache.kafka.clients.NetworkClient:677)
> [2018-10-24 20:38:52,488] ERROR [Producer clientId=test-client] Connection to 
> node -3 (localhost/127.0.0.1:45909) failed authentication due to: SSL 
> handshake failed (org.apache.kafka.clients.NetworkClient:677)
> [2018-10-24 20:38:52,491] ERROR [Producer clientId=test-client] Connection to 
> node -1 (localhost/127.0.0.1:33492) failed authentication due to: SSL 
> handshake failed (org.apache.kafka.clients.NetworkClient:677)
> [2018-10-24 20:38:52,619] ERROR [Producer clientId=test-client] Connection to 
> node -2 (localhost/127.0.0.1:32921) failed authentication due to: SSL 
> handshake failed (org.apache.kafka.clients.NetworkClient:677)
> Completed updating config for broker: 0.
> Completed updating config for broker: 1.
> [2018-10-24 20:38:52,887] ERROR [Producer clientId=test-client] Connection to 
> node -3 (localhost/127.0.0.1:45909) failed authentication due to: SSL 
> handshake failed (org.apache.kafka.clients.NetworkClient:677)
> Completed updating config for broker: 2.
> [2018-10-24 20:38:53,344] ERROR [Producer clientId=test-client] Connection to 
> node -1 (localhost/127.0.0.1:33492) failed authentication due to: SSL 
> handshake failed (org.apache.kafka.clients.NetworkClient:677)
> [2018-10-24 20:38:53,361] ERROR [Producer clientId=test-client] Connection to 
> node -2 (localhost/127.0.0.1:32921) failed authentication due to: SSL 
> handshake failed (org.apache.kafka.clients.NetworkClient:677)
> [2018-10-24 20:38:53,361] ERROR [Producer clientId=test-client] Connection to 
> node -3 (localhost/127.0.0.1:45909) failed authentication due to: SSL 
> handshake failed (org.apache.kafka.clients.NetworkClient:677)
> [2018-10-24 20:38:53,473] ERROR [Producer clientId=test-client] Connection to 
> node -1 (localhost/127.0.0.1:33492) failed authentication due to: SSL 
> handshake failed (org.apache.kafka.clients.NetworkClient:677)
> [2018-10-24 20:38:53,475] ERROR [Producer clientId=test-client] Connection to 
> node -3 (localhost/127.0.0.1:45909) failed authentication due to: SSL 
> handshake failed (org.apache.kafka.clients.NetworkClient:677)
> [2018-10-24 20:38:53,601] ERROR [Producer clientId=test-client] Connection to 
> node -2 (localhost/127.0.0.1:32921) failed authentication due to: SSL 
> handshake failed (org.apache.kafka.clients.NetworkClient:677)
> [2018-10-24 20:38:53,964] ERROR [Producer clientId=test-client] Connection to 
> node -3 (localhost/127.0.0.1:45909) failed authentication due to: SSL 
> handshake failed (org.apache.kafka.clients.NetworkClient:677)
> [2018-10-24 20:38:54,102] ERROR [Producer clientId=test-client] Connection to 
> node -1 (localhost/127.0.0.1:33492) failed authentication due to: SSL 
> handshake failed (org.apache.kafka.clients.NetworkClient:677)
> [2018-10-24 20:38:54,119] ERROR [Producer clientId=test-client] Connection to 
> node -2 (localhost/127.0.0.1:32921) failed authentication due to: SSL 
> handshake failed (org.apache.kafka.clients.NetworkClient:677)
> [2018-10-24 20:38:54,886] ERROR [Producer clientId=test-client] Connection to 
> node -3 (localhost/127.0.0.1:45909) failed authentication due to: SSL 
> handshake failed (org.apache.kafka.clients.NetworkClient:677)
> [2018-10-24 20:38:55,053] ERROR [Producer clientId=test-client] Connection to 
> node -1 (localhost/127.0.0.1:33492) failed authentication due to: SSL 
> handshake failed (org.apache.kafka.clients.NetworkClient:677)
> [2018-10-24 20:38:55,323] ERROR [Producer clientId=test-client] Connection to 
> node -2 (localhost/127.0.0.1:32921) failed authentication due to: SSL 
> handshake failed (org.apache.kafka.clients.NetworkClient:677)
> [2018-10-24 20:38:55,937] ERROR [Producer clientId=test-client] Connection to 
> node -1 (localhost/127.0.0.1:33492) failed authentication due to: SSL 
> handshake failed (org.apache.kafka.clients.NetworkClient:677)
> [2018-10-24 20:38:55,952] ERROR [Producer clientId=test-client] Connection to 
> node -3 (localhost/127.0.0.1:45909) failed authentication due to: SSL 
> handshake failed (org.apache.kafka.clients.NetworkClient:677)
> [2018-10-24 20:38:56,485] ERROR [Producer clientId=test-client] Connection to 
> node -2 (localhost/127.0.0.1:32921) failed authentication due to: SSL 
> handshake failed (org.apache.kafka.clients.NetworkClient:677)
> [2018-10-24 20:38:56,802] ERROR [Producer clientId=test-client] Connection to 
> node -3 (localhost/127.0.0.1:45909) failed authentication due to: SSL 
> handshake failed (org.apache.kafka.clients.NetworkClient:677)
> Completed Updating config for entity: brokers '0'.
> Completed Updating config for entity: brokers '1'.
> Completed Updating config for entity: brokers '2'.
> [2018-10-24 20:39:01,439] WARN Unable to read additional data from client 
> sessionid 0x101d8ca10dc0005, likely client has closed socket 
> (org.apache.zookeeper.server.NIOServerCnxn:376)
> [2018-10-24 20:39:01,859] 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.
> [2018-10-24 20:39:01,887] 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.
> [2018-10-24 20:39:01,888] 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.
> [2018-10-24 20:39:01,895] 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.
> [2018-10-24 20:39:01,949] 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.
> [2018-10-24 20:39:01,950] 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.
> 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'.
> [2018-10-24 20:39:12,810] 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.
> [2018-10-24 20:39:12,811] 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.
> [2018-10-24 20:39:12,838] 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.
> [2018-10-24 20:39:12,843] 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.
> [2018-10-24 20:39:12,854] 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.
> [2018-10-24 20:39:12,859] 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.
> [2018-10-24 20:39:12,860] 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.
> [2018-10-24 20:39:19,802] ERROR [kafka-log-cleaner-thread-1]: 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)
> [2018-10-24 20:39:19,802] 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
(v7.6.3#76005)

Reply via email to