You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Dong Lin (JIRA)" <ji...@apache.org> on 2018/11/16 23:31:00 UTC
[jira] [Commented] (KAFKA-7541) Transient Failure:
kafka.server.DynamicBrokerReconfigurationTest.testUncleanLeaderElectionEnable
[ 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/localhost@EXAMPLE.COM tryFirstPass is false useFirstPass is false storePass is false clearPass is false
> principal is kafka/localhost@EXAMPLE.COM
> Will use keytab
> Commit Succeeded
> Debug is true storeKey true useTicketCache false useKeyTab true doNotPrompt false ticketCache is null isInitiator true KeyTab is /tmp/kafka1107632288158235049.tmp refreshKrb5Config is false principal is kafka/localhost@EXAMPLE.COM tryFirstPass is false useFirstPass is false storePass is false clearPass is false
> principal is kafka/localhost@EXAMPLE.COM
> Will use keytab
> Commit Succeeded
> [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 client@EXAMPLE.COM tryFirstPass is false useFirstPass is false storePass is false clearPass is false
> principal is client@EXAMPLE.COM
> Will use keytab
> Commit Succeeded
> [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)