[
https://issues.apache.org/jira/browse/KAFKA-7541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16690130#comment-16690130
]
Dong Lin commented on KAFKA-7541:
---------------------------------
According to the source code
DynamicBrokerReconfigurationTest.testUncleanLeaderElectionEnable(), the test
will fail with the exception above if leader election is not completed within
15 seconds. Thus the test may fail if there is long GC. We can reduce the
chance of the test failure by increasing the wait time.
Given the above understanding and the fact that the test passes with high
probability, this flaky test does not indicate bug and should not be a blocking
issue for 2.1.0 release.
> Transient Failure:
> kafka.server.DynamicBrokerReconfigurationTest.testUncleanLeaderElectionEnable
> ------------------------------------------------------------------------------------------------
>
> Key: KAFKA-7541
> URL: https://issues.apache.org/jira/browse/KAFKA-7541
> Project: Kafka
> Issue Type: Sub-task
> Reporter: John Roesler
> Priority: Major
>
> 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)
