[KAFKA-7541] Transient Failure: kafka.server.DynamicBrokerReconfigurationTest.testUncleanLeaderElectionEnable - ASF JIRA

XML

Word

Printable

JSON

Details

Type: Sub-task
Status: Resolved
Priority: Critical
Resolution: Duplicate
Affects Version/s: 2.2.0
Fix Version/s: None
Component/s: core, unit tests
Labels:
- flaky-test

Description

Observed on Java 11: https://builds.apache.org/job/kafka-pr-jdk11-scala2.12/264/testReport/junit/kafka.server/DynamicBrokerReconfigurationTest/testUncleanLeaderElectionEnable/

Stacktrace:

java.lang.AssertionError: Unclean leader not elected
	at org.junit.Assert.fail(Assert.java:88)
	at org.junit.Assert.assertTrue(Assert.java:41)
	at kafka.server.DynamicBrokerReconfigurationTest.testUncleanLeaderElectionEnable(DynamicBrokerReconfigurationTest.scala: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)

Stdout:

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)

Attachments

Issue Links

is duplicated by

KAFKA-7976 Flaky Test DynamicBrokerReconfigurationTest#testUncleanLeaderElectionEnable

Resolved

is related to

KAFKA-7988 Flaky Test DynamicBrokerReconfigurationTest#testThreadPoolResize

Resolved

relates to

KAFKA-6904 DynamicBrokerReconfigurationTest#testAdvertisedListenerUpdate is flaky

Resolved

Activity

People

Assignee:: Unassigned

Reporter:: John Roesler

Votes:: 0 Vote for this issue

Watchers:: 3 Start watching this issue

Dates

Created:: 24/Oct/18 23:20

Updated:: 01/Mar/19 07:24

Resolved:: 01/Mar/19 07:24