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