kafka-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Balint Molnar (JIRA)" <j...@apache.org>
Subject [jira] [Assigned] (KAFKA-5184) Transient failure: MultipleListenersWithAdditionalJaasContextTest.testProduceConsume
Date Mon, 08 May 2017 08:01:04 GMT

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

Balint Molnar reassigned KAFKA-5184:
------------------------------------

    Assignee: Balint Molnar

> Transient failure: MultipleListenersWithAdditionalJaasContextTest.testProduceConsume
> ------------------------------------------------------------------------------------
>
>                 Key: KAFKA-5184
>                 URL: https://issues.apache.org/jira/browse/KAFKA-5184
>             Project: Kafka
>          Issue Type: Sub-task
>            Reporter: Xavier Léauté
>            Assignee: Balint Molnar
>
> https://builds.apache.org/job/kafka-pr-jdk8-scala2.12/3574/testReport/junit/kafka.server/MultipleListenersWithAdditionalJaasContextTest/testProduceConsume/
> {code}
> Error Message
> java.lang.AssertionError: Partition [SECURE_INTERNAL,1] metadata not propagated after 15000 ms
> Stacktrace
> java.lang.AssertionError: Partition [SECURE_INTERNAL,1] metadata not propagated after 15000 ms
> 	at kafka.utils.TestUtils$.fail(TestUtils.scala:311)
> 	at kafka.utils.TestUtils$.waitUntilTrue(TestUtils.scala:811)
> 	at kafka.utils.TestUtils$.waitUntilMetadataIsPropagated(TestUtils.scala:857)
> 	at kafka.utils.TestUtils$.$anonfun$createTopic$1(TestUtils.scala:254)
> 	at kafka.utils.TestUtils$.$anonfun$createTopic$1$adapted(TestUtils.scala:253)
> 	at scala.collection.TraversableLike.$anonfun$map$1(TraversableLike.scala:234)
> 	at scala.collection.immutable.Range.foreach(Range.scala:156)
> 	at scala.collection.TraversableLike.map(TraversableLike.scala:234)
> 	at scala.collection.TraversableLike.map$(TraversableLike.scala:227)
> 	at scala.collection.AbstractTraversable.map(Traversable.scala:104)
> 	at kafka.utils.TestUtils$.createTopic(TestUtils.scala:253)
> 	at kafka.server.MultipleListenersWithSameSecurityProtocolBaseTest.$anonfun$setUp$3(MultipleListenersWithSameSecurityProtocolBaseTest.scala:109)
> 	at kafka.server.MultipleListenersWithSameSecurityProtocolBaseTest.$anonfun$setUp$3$adapted(MultipleListenersWithSameSecurityProtocolBaseTest.scala:106)
> 	at scala.collection.mutable.ResizableArray.foreach(ResizableArray.scala:59)
> 	at scala.collection.mutable.ResizableArray.foreach$(ResizableArray.scala:52)
> 	at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:48)
> 	at kafka.server.MultipleListenersWithSameSecurityProtocolBaseTest.setUp(MultipleListenersWithSameSecurityProtocolBaseTest.scala:106)
> 	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> 	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> 	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> 	at java.lang.reflect.Method.invoke(Method.java:498)
> 	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.RunBefores.evaluate(RunBefores.java:24)
> 	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.runners.ParentRunner.run(ParentRunner.java:363)
> 	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:114)
> 	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:57)
> 	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:66)
> 	at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:51)
> 	at sun.reflect.GeneratedMethodAccessor4.invoke(Unknown Source)
> 	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> 	at java.lang.reflect.Method.invoke(Method.java:498)
> 	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:109)
> 	at sun.reflect.GeneratedMethodAccessor3.invoke(Unknown Source)
> 	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> 	at java.lang.reflect.Method.invoke(Method.java:498)
> 	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:147)
> 	at org.gradle.internal.remote.internal.hub.MessageHubBackedObjectConnection$DispatchWrapper.dispatch(MessageHubBackedObjectConnection.java:129)
> 	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.StoppableExecutorImpl$1.run(StoppableExecutorImpl.java:46)
> 	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
> 	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
> 	at java.lang.Thread.run(Thread.java:745)
> Standard Output
> [2017-05-06 01:28:49,380] WARN Session 0x15bdb5b6dbc0001 for server null, unexpected error, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn:1162)
> java.net.ConnectException: Connection refused
> 	at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
> 	at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
> 	at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)
> 	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)
> [2017-05-06 01:28:49,523] WARN Session 0x15bdb5b913b0002 for server null, unexpected error, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn:1162)
> java.net.ConnectException: Connection refused
> 	at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
> 	at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
> 	at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)
> 	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)
> [2017-05-06 01:28:49,620] WARN Session 0x15bdb5b913b0001 for server null, unexpected error, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn:1162)
> java.net.ConnectException: Connection refused
> 	at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
> 	at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
> 	at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)
> 	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)
> [2017-05-06 01:28:50,701] WARN Session 0x15bdb5b6dbc0002 for server null, unexpected error, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn:1162)
> java.net.ConnectException: Connection refused
> 	at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
> 	at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
> 	at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)
> 	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)
> [2017-05-06 01:28:50,900] WARN Session 0x15bdb5b6dbc0001 for server null, unexpected error, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn:1162)
> java.net.ConnectException: Connection refused
> 	at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
> 	at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
> 	at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)
> 	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)
> [2017-05-06 01:28:51,103] WARN Session 0x15bdb5b913b0001 for server null, unexpected error, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn:1162)
> java.net.ConnectException: Connection refused
> 	at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
> 	at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
> 	at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)
> 	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)
> [2017-05-06 01:28:51,620] WARN Session 0x15bdb5b913b0002 for server null, unexpected error, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn:1162)
> java.net.ConnectException: Connection refused
> 	at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
> 	at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
> 	at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)
> 	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)
> [2017-05-06 01:28:52,121] WARN Session 0x15bdb5b6dbc0002 for server null, unexpected error, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn:1162)
> java.net.ConnectException: Connection refused
> 	at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
> 	at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
> 	at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)
> 	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)
> [2017-05-06 01:28:52,222] WARN Session 0x15bdb5b6dbc0001 for server null, unexpected error, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn:1162)
> java.net.ConnectException: Connection refused
> 	at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
> 	at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
> 	at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)
> 	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)
> [2017-05-06 01:28:52,595] WARN Session 0x15bdb5b913b0001 for server null, unexpected error, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn:1162)
> java.net.ConnectException: Connection refused
> 	at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
> 	at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
> 	at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)
> 	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)
> [2017-05-06 01:28:53,117] ERROR ZKShutdownHandler is not registered, so ZooKeeper server won't take any action on ERROR or SHUTDOWN server state changes (org.apache.zookeeper.server.ZooKeeperServer:472)
> Debug is  true storeKey true useTicketCache false useKeyTab true doNotPrompt false ticketCache is null isInitiator true KeyTab is /tmp/kafka370804941142807721.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 
> [2017-05-06 01:28:53,652] WARN Session 0x15bdb5b6dbc0002 for server null, unexpected error, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn:1162)
> java.net.ConnectException: Connection refused
> 	at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
> 	at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
> 	at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)
> 	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)
> [2017-05-06 01:28:53,681] WARN Session 0x15bdb5b6dbc0001 for server null, unexpected error, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn:1162)
> java.net.ConnectException: Connection refused
> 	at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
> 	at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
> 	at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)
> 	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)
> [2017-05-06 01:28:54,245] WARN Unable to reconnect to ZooKeeper service, session 0x15bdb5b913b0001 has expired (org.apache.zookeeper.ClientCnxn:1285)
> [2017-05-06 01:28:54,650] ERROR [ReplicaFetcherThread-0-0]: Error for partition [__consumer_offsets,21] to broker 0:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. (kafka.server.ReplicaFetcherThread:99)
> [2017-05-06 01:28:54,651] ERROR [ReplicaFetcherThread-0-0]: Error for partition [__consumer_offsets,27] to broker 0:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. (kafka.server.ReplicaFetcherThread:99)
> [2017-05-06 01:28:54,652] ERROR [ReplicaFetcherThread-0-0]: Error for partition [__consumer_offsets,7] to broker 0:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. (kafka.server.ReplicaFetcherThread:99)
> [2017-05-06 01:28:54,652] ERROR [ReplicaFetcherThread-0-0]: Error for partition [__consumer_offsets,9] to broker 0:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. (kafka.server.ReplicaFetcherThread:99)
> [2017-05-06 01:28:54,652] ERROR [ReplicaFetcherThread-0-0]: Error for partition [__consumer_offsets,25] to broker 0:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. (kafka.server.ReplicaFetcherThread:99)
> [2017-05-06 01:28:54,653] ERROR [ReplicaFetcherThread-0-0]: Error for partition [__consumer_offsets,35] to broker 0:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. (kafka.server.ReplicaFetcherThread:99)
> [2017-05-06 01:28:54,653] ERROR [ReplicaFetcherThread-0-0]: Error for partition [__consumer_offsets,41] to broker 0:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. (kafka.server.ReplicaFetcherThread:99)
> [2017-05-06 01:28:54,653] ERROR [ReplicaFetcherThread-0-0]: Error for partition [__consumer_offsets,33] to broker 0:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. (kafka.server.ReplicaFetcherThread:99)
> [2017-05-06 01:28:54,654] ERROR [ReplicaFetcherThread-0-0]: Error for partition [__consumer_offsets,23] to broker 0:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. (kafka.server.ReplicaFetcherThread:99)
> [2017-05-06 01:28:54,654] ERROR [ReplicaFetcherThread-0-0]: Error for partition [__consumer_offsets,49] to broker 0:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. (kafka.server.ReplicaFetcherThread:99)
> [2017-05-06 01:28:54,654] ERROR [ReplicaFetcherThread-0-0]: Error for partition [__consumer_offsets,47] to broker 0:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. (kafka.server.ReplicaFetcherThread:99)
> [2017-05-06 01:28:54,655] ERROR [ReplicaFetcherThread-0-0]: Error for partition [__consumer_offsets,31] to broker 0:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. (kafka.server.ReplicaFetcherThread:99)
> [2017-05-06 01:28:54,655] ERROR [ReplicaFetcherThread-0-0]: Error for partition [__consumer_offsets,3] to broker 0:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. (kafka.server.ReplicaFetcherThread:99)
> [2017-05-06 01:28:54,655] ERROR [ReplicaFetcherThread-0-0]: Error for partition [__consumer_offsets,37] to broker 0:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. (kafka.server.ReplicaFetcherThread:99)
> [2017-05-06 01:28:54,656] ERROR [ReplicaFetcherThread-0-0]: Error for partition [__consumer_offsets,15] to broker 0:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. (kafka.server.ReplicaFetcherThread:99)
> [2017-05-06 01:28:54,656] ERROR [ReplicaFetcherThread-0-0]: Error for partition [__consumer_offsets,17] to broker 0:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. (kafka.server.ReplicaFetcherThread:99)
> [2017-05-06 01:28:54,656] ERROR [ReplicaFetcherThread-0-0]: Error for partition [__consumer_offsets,19] to broker 0:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. (kafka.server.ReplicaFetcherThread:99)
> [2017-05-06 01:28:54,657] ERROR [ReplicaFetcherThread-0-0]: Error for partition [__consumer_offsets,11] to broker 0:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. (kafka.server.ReplicaFetcherThread:99)
> [2017-05-06 01:28:54,657] ERROR [ReplicaFetcherThread-0-0]: Error for partition [__consumer_offsets,13] to broker 0:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. (kafka.server.ReplicaFetcherThread:99)
> [2017-05-06 01:28:54,657] ERROR [ReplicaFetcherThread-0-0]: Error for partition [__consumer_offsets,43] to broker 0:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. (kafka.server.ReplicaFetcherThread:99)
> [2017-05-06 01:28:54,657] ERROR [ReplicaFetcherThread-0-0]: Error for partition [__consumer_offsets,39] to broker 0:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. (kafka.server.ReplicaFetcherThread:99)
> [2017-05-06 01:28:54,658] ERROR [ReplicaFetcherThread-0-0]: Error for partition [__consumer_offsets,45] to broker 0:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. (kafka.server.ReplicaFetcherThread:99)
> [2017-05-06 01:28:54,658] ERROR [ReplicaFetcherThread-0-0]: Error for partition [__consumer_offsets,1] to broker 0:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. (kafka.server.ReplicaFetcherThread:99)
> [2017-05-06 01:28:54,658] ERROR [ReplicaFetcherThread-0-0]: Error for partition [__consumer_offsets,5] to broker 0:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. (kafka.server.ReplicaFetcherThread:99)
> [2017-05-06 01:28:54,658] ERROR [ReplicaFetcherThread-0-0]: Error for partition [__consumer_offsets,29] to broker 0:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. (kafka.server.ReplicaFetcherThread:99)
> [2017-05-06 01:28:54,832] ERROR Haven't been able to send leader and isr requests, current state of the map is Map(1 -> Map(__consumer_offsets-49 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-27 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-19 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-13 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-35 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-5 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-43 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-21 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-37 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-29 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-7 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-23 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-45 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-15 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-31 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-9 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-1 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-17 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-39 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-47 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-3 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-25 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-41 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-33 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-11 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1)), 0 -> Map(__consumer_offsets-38 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-16 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-8 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-2 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-46 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-24 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-32 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-10 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-48 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-40 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-18 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-34 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-26 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-4 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-42 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-20 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-12 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-28 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-6 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-44 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-36 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-14 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-30 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-22 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-0 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0))). Exception message: kafka.common.BrokerEndPointNotAvailableException: End point with protocol label ListenerName(PLAINTEXT) not found for broker 0 (kafka.controller.ControllerBrokerRequestBatch:99)
> [2017-05-06 01:28:54,834] ERROR Haven't been able to send metadata update requests to brokers Set(0, 1), current state of the partition info is Map(). Exception message: kafka.common.BrokerEndPointNotAvailableException: End point with protocol label ListenerName(PLAINTEXT) not found for broker 0 (kafka.controller.ControllerBrokerRequestBatch:99)
> [2017-05-06 01:28:54,836] ERROR [Replica state machine on controller 0]: Error while moving some replicas to NewReplica state (kafka.controller.ReplicaStateMachine:105)
> java.lang.IllegalStateException: kafka.common.BrokerEndPointNotAvailableException: End point with protocol label ListenerName(PLAINTEXT) not found for broker 0
> 	at kafka.controller.ControllerBrokerRequestBatch.sendRequestsToBrokers(ControllerChannelManager.scala:459)
> 	at kafka.controller.ReplicaStateMachine.handleStateChanges(ReplicaStateMachine.scala:88)
> 	at kafka.controller.KafkaController.onNewPartitionCreation(KafkaController.scala:443)
> 	at kafka.controller.KafkaController.onNewTopicCreation(KafkaController.scala:431)
> 	at kafka.controller.KafkaController$TopicChange.process(KafkaController.scala:1200)
> 	at kafka.controller.KafkaController$ControllerEventThread.doWork(KafkaController.scala:1147)
> 	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:64)
> Caused by: kafka.common.BrokerEndPointNotAvailableException: End point with protocol label ListenerName(PLAINTEXT) not found for broker 0
> 	at kafka.cluster.Broker.$anonfun$getNode$1(Broker.scala:172)
> 	at scala.collection.MapLike.getOrElse(MapLike.scala:128)
> 	at scala.collection.MapLike.getOrElse$(MapLike.scala:126)
> 	at scala.collection.AbstractMap.getOrElse(Map.scala:59)
> 	at kafka.cluster.Broker.getNode(Broker.scala:172)
> 	at kafka.controller.ControllerBrokerRequestBatch.$anonfun$sendRequestsToBrokers$6(ControllerChannelManager.scala:361)
> 	at scala.collection.TraversableLike.$anonfun$map$1(TraversableLike.scala:234)
> 	at scala.collection.immutable.Set$Set1.foreach(Set.scala:95)
> 	at scala.collection.TraversableLike.map(TraversableLike.scala:234)
> 	at scala.collection.TraversableLike.map$(TraversableLike.scala:227)
> 	at scala.collection.AbstractSet.scala$collection$SetLike$$super$map(Set.scala:47)
> 	at scala.collection.SetLike.map(SetLike.scala:101)
> 	at scala.collection.SetLike.map$(SetLike.scala:101)
> 	at scala.collection.AbstractSet.map(Set.scala:47)
> 	at kafka.controller.ControllerBrokerRequestBatch.$anonfun$sendRequestsToBrokers$1(ControllerChannelManager.scala:360)
> 	at kafka.controller.ControllerBrokerRequestBatch.$anonfun$sendRequestsToBrokers$1$adapted(ControllerChannelManager.scala:351)
> 	at scala.collection.mutable.HashMap.$anonfun$foreach$1(HashMap.scala:138)
> 	at scala.collection.mutable.HashTable.foreachEntry(HashTable.scala:236)
> 	at scala.collection.mutable.HashTable.foreachEntry$(HashTable.scala:229)
> 	at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:40)
> 	at scala.collection.mutable.HashMap.foreach(HashMap.scala:138)
> 	at kafka.controller.ControllerBrokerRequestBatch.sendRequestsToBrokers(ControllerChannelManager.scala:351)
> 	... 6 more
> [2017-05-06 01:28:54,894] WARN Unable to reconnect to ZooKeeper service, session 0x15bdb5b913b0002 has expired (org.apache.zookeeper.ClientCnxn:1285)
> [2017-05-06 01:28:55,047] ERROR [Replica state machine on controller 0]: Error while moving some replicas to OnlineReplica state (kafka.controller.ReplicaStateMachine:105)
> java.lang.IllegalStateException: Controller to broker state change requests batch is not empty while creating a new one. Some LeaderAndIsr state changes Map(1 -> Map(__consumer_offsets-49 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-27 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-19 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-13 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-35 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-5 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-43 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-21 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-37 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-29 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-7 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-23 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-45 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-15 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-31 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-9 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-1 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-17 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-39 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-47 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-3 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-25 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-41 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-33 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-11 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1)), 0 -> Map(__consumer_offsets-38 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-16 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-8 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-2 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-46 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-24 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-32 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-10 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-48 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-40 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-18 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-34 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-26 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-4 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-42 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-20 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-12 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-28 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-6 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-44 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-36 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-14 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-30 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-22 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-0 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0))) might be lost 
> 	at kafka.controller.ControllerBrokerRequestBatch.newBatch(ControllerChannelManager.scala:263)
> 	at kafka.controller.ReplicaStateMachine.handleStateChanges(ReplicaStateMachine.scala:86)
> 	at kafka.controller.KafkaController.onNewPartitionCreation(KafkaController.scala:445)
> 	at kafka.controller.KafkaController.onNewTopicCreation(KafkaController.scala:431)
> 	at kafka.controller.KafkaController$TopicChange.process(KafkaController.scala:1200)
> 	at kafka.controller.KafkaController$ControllerEventThread.doWork(KafkaController.scala:1147)
> 	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:64)
> [2017-05-06 01:28:55,063] WARN Session 0x15bdb5b6dbc0002 for server null, unexpected error, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn:1162)
> java.net.ConnectException: Connection refused
> 	at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
> 	at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
> 	at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)
> 	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)
> [2017-05-06 01:28:55,259] WARN Session 0x15bdb5b6dbc0001 for server null, unexpected error, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn:1162)
> java.net.ConnectException: Connection refused
> 	at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
> 	at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
> 	at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)
> 	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)
> [2017-05-06 01:28:56,721] WARN Session 0x15bdb5b6dbc0002 for server null, unexpected error, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn:1162)
> java.net.ConnectException: Connection refused
> 	at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
> 	at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
> 	at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)
> 	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)
> [2017-05-06 01:28:56,892] WARN Session 0x15bdb5b6dbc0001 for server null, unexpected error, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn:1162)
> java.net.ConnectException: Connection refused
> 	at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
> 	at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
> 	at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)
> 	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)
> [2017-05-06 01:28:58,309] WARN Session 0x15bdb5b6dbc0002 for server null, unexpected error, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn:1162)
> java.net.ConnectException: Connection refused
> 	at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
> 	at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
> 	at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)
> 	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)
> [2017-05-06 01:28:58,794] WARN Session 0x15bdb5b6dbc0001 for server null, unexpected error, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn:1162)
> java.net.ConnectException: Connection refused
> 	at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
> 	at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
> 	at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)
> 	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)
> [2017-05-06 01:28:59,621] WARN Session 0x15bdb5b6dbc0002 for server null, unexpected error, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn:1162)
> java.net.ConnectException: Connection refused
> 	at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
> 	at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
> 	at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)
> 	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)
> [2017-05-06 01:28:59,925] ERROR [Replica state machine on controller 0]: Error while moving some replicas to NewReplica state (kafka.controller.ReplicaStateMachine:105)
> java.lang.IllegalStateException: Controller to broker state change requests batch is not empty while creating a new one. Some LeaderAndIsr state changes Map(1 -> Map(__consumer_offsets-49 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-27 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-19 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-13 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-35 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-5 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-43 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-21 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-37 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-29 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-7 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-23 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-45 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-15 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-31 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-9 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-1 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-17 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-39 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-47 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-3 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-25 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-41 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-33 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-11 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1)), 0 -> Map(__consumer_offsets-38 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-16 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-8 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-2 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-46 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-24 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-32 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-10 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-48 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-40 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-18 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-34 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-26 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-4 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-42 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-20 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-12 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-28 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-6 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-44 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-36 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-14 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-30 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-22 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-0 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0))) might be lost 
> 	at kafka.controller.ControllerBrokerRequestBatch.newBatch(ControllerChannelManager.scala:263)
> 	at kafka.controller.ReplicaStateMachine.handleStateChanges(ReplicaStateMachine.scala:86)
> 	at kafka.controller.KafkaController.onNewPartitionCreation(KafkaController.scala:443)
> 	at kafka.controller.KafkaController.onNewTopicCreation(KafkaController.scala:431)
> 	at kafka.controller.KafkaController$TopicChange.process(KafkaController.scala:1200)
> 	at kafka.controller.KafkaController$ControllerEventThread.doWork(KafkaController.scala:1147)
> 	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:64)
> [2017-05-06 01:28:59,940] ERROR Haven't been able to send leader and isr requests, current state of the map is Map(1 -> Map(SECURE_INTERNAL-1 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0)), 0 -> Map(SECURE_INTERNAL-1 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0))). Exception message: kafka.common.BrokerEndPointNotAvailableException: End point with protocol label ListenerName(PLAINTEXT) not found for broker 1 (kafka.controller.ControllerBrokerRequestBatch:99)
> [2017-05-06 01:28:59,941] ERROR Haven't been able to send metadata update requests to brokers Set(0, 1), current state of the partition info is Map(SECURE_INTERNAL-1 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0)). Exception message: kafka.common.BrokerEndPointNotAvailableException: End point with protocol label ListenerName(PLAINTEXT) not found for broker 1 (kafka.controller.ControllerBrokerRequestBatch:99)
> [2017-05-06 01:28:59,943] ERROR [Partition state machine on Controller 0]: Error while moving some partitions to OnlinePartition state (kafka.controller.PartitionStateMachine:105)
> java.lang.IllegalStateException: kafka.common.BrokerEndPointNotAvailableException: End point with protocol label ListenerName(PLAINTEXT) not found for broker 1
> 	at kafka.controller.ControllerBrokerRequestBatch.sendRequestsToBrokers(ControllerChannelManager.scala:459)
> 	at kafka.controller.PartitionStateMachine.handleStateChanges(PartitionStateMachine.scala:113)
> 	at kafka.controller.KafkaController.onNewPartitionCreation(KafkaController.scala:444)
> 	at kafka.controller.KafkaController.onNewTopicCreation(KafkaController.scala:431)
> 	at kafka.controller.KafkaController$TopicChange.process(KafkaController.scala:1200)
> 	at kafka.controller.KafkaController$ControllerEventThread.doWork(KafkaController.scala:1147)
> 	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:64)
> Caused by: kafka.common.BrokerEndPointNotAvailableException: End point with protocol label ListenerName(PLAINTEXT) not found for broker 1
> 	at kafka.cluster.Broker.$anonfun$getNode$1(Broker.scala:172)
> 	at scala.collection.MapLike.getOrElse(MapLike.scala:128)
> 	at scala.collection.MapLike.getOrElse$(MapLike.scala:126)
> 	at scala.collection.AbstractMap.getOrElse(Map.scala:59)
> 	at kafka.cluster.Broker.getNode(Broker.scala:172)
> 	at kafka.controller.ControllerBrokerRequestBatch.$anonfun$sendRequestsToBrokers$6(ControllerChannelManager.scala:361)
> 	at scala.collection.TraversableLike.$anonfun$map$1(TraversableLike.scala:234)
> 	at scala.collection.immutable.Set$Set1.foreach(Set.scala:95)
> 	at scala.collection.TraversableLike.map(TraversableLike.scala:234)
> 	at scala.collection.TraversableLike.map$(TraversableLike.scala:227)
> 	at scala.collection.AbstractSet.scala$collection$SetLike$$super$map(Set.scala:47)
> 	at scala.collection.SetLike.map(SetLike.scala:101)
> 	at scala.collection.SetLike.map$(SetLike.scala:101)
> 	at scala.collection.AbstractSet.map(Set.scala:47)
> 	at kafka.controller.ControllerBrokerRequestBatch.$anonfun$sendRequestsToBrokers$1(ControllerChannelManager.scala:360)
> 	at kafka.controller.ControllerBrokerRequestBatch.$anonfun$sendRequestsToBrokers$1$adapted(ControllerChannelManager.scala:351)
> 	at scala.collection.mutable.HashMap.$anonfun$foreach$1(HashMap.scala:138)
> 	at scala.collection.mutable.HashTable.foreachEntry(HashTable.scala:236)
> 	at scala.collection.mutable.HashTable.foreachEntry$(HashTable.scala:229)
> 	at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:40)
> 	at scala.collection.mutable.HashMap.foreach(HashMap.scala:138)
> 	at kafka.controller.ControllerBrokerRequestBatch.sendRequestsToBrokers(ControllerChannelManager.scala:351)
> 	... 6 more
> [2017-05-06 01:28:59,948] ERROR [Replica state machine on controller 0]: Error while moving some replicas to OnlineReplica state (kafka.controller.ReplicaStateMachine:105)
> java.lang.IllegalStateException: Controller to broker state change requests batch is not empty while creating a new one. Some LeaderAndIsr state changes Map(1 -> Map(__consumer_offsets-49 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-27 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-19 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-13 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-35 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-5 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-43 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-21 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-37 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-29 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-7 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-23 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-45 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-15 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-31 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-9 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-1 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-17 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-39 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-47 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-3 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-25 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-41 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-33 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1), __consumer_offsets-11 -> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1)), 0 -> Map(__consumer_offsets-38 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-16 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-8 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-2 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-46 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-24 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-32 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-10 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-48 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-40 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-18 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-34 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-26 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-4 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-42 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-20 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-12 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-28 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-6 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-44 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-36 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-14 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-30 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-22 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0), __consumer_offsets-0 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:1,0))) might be lost 
> 	at kafka.controller.ControllerBrokerRequestBatch.newBatch(ControllerChannelManager.scala:263)
> 	at kafka.controller.ReplicaStateMachine.handleStateChanges(ReplicaStateMachine.scala:86)
> 	at kafka.controller.KafkaController.onNewPartitionCreation(KafkaController.scala:445)
> 	at kafka.controller.KafkaController.onNewTopicCreation(KafkaController.scala:431)
> 	at kafka.controller.KafkaController$TopicChange.process(KafkaController.scala:1200)
> 	at kafka.controller.KafkaController$ControllerEventThread.doWork(KafkaController.scala:1147)
> 	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:64)
> [2017-05-06 01:29:00,736] WARN Session 0x15bdb5b6dbc0001 for server null, unexpected error, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn:1162)
> java.net.ConnectException: Connection refused
> 	at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
> 	at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
> 	at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)
> 	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)
> [2017-05-06 01:29:01,420] WARN Session 0x15bdb5b6dbc0002 for server null, unexpected error, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn:1162)
> java.net.ConnectException: Connection refused
> 	at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
> 	at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
> 	at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)
> 	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)
> [2017-05-06 01:29:02,707] WARN Session 0x15bdb5b6dbc0002 for server null, unexpected error, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn:1162)
> java.net.ConnectException: Connection refused
> 	at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
> 	at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
> 	at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)
> 	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)
> [2017-05-06 01:29:02,832] WARN Session 0x15bdb5b6dbc0001 for server null, unexpected error, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn:1162)
> java.net.ConnectException: Connection refused
> 	at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
> 	at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
> 	at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)
> 	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)
> [2017-05-06 01:29:04,550] WARN Session 0x15bdb5b6dbc0002 for server null, unexpected error, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn:1162)
> java.net.ConnectException: Connection refused
> 	at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
> 	at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
> 	at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)
> 	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)
> [2017-05-06 01:29:04,574] WARN Session 0x15bdb5b6dbc0001 for server null, unexpected error, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn:1162)
> java.net.ConnectException: Connection refused
> 	at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
> 	at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
> 	at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)
> 	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)
> [2017-05-06 01:29:05,722] WARN Session 0x15bdb5b6dbc0001 for server null, unexpected error, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn:1162)
> java.net.ConnectException: Connection refused
> 	at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
> 	at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
> 	at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)
> 	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)
> [2017-05-06 01:29:06,495] WARN Session 0x15bdb5b6dbc0002 for server null, unexpected error, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn:1162)
> java.net.ConnectException: Connection refused
> 	at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
> 	at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
> 	at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)
> 	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)
> [2017-05-06 01:29:07,557] WARN Session 0x15bdb5b6dbc0001 for server null, unexpected error, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn:1162)
> java.net.ConnectException: Connection refused
> 	at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
> 	at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
> 	at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)
> 	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)
> [2017-05-06 01:29:08,591] WARN Session 0x15bdb5b6dbc0002 for server null, unexpected error, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn:1162)
> java.net.ConnectException: Connection refused
> 	at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
> 	at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
> 	at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)
> 	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)
> [2017-05-06 01:29:08,773] WARN Session 0x15bdb5b6dbc0001 for server null, unexpected error, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn:1162)
> java.net.ConnectException: Connection refused
> 	at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
> 	at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
> 	at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)
> 	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)
> [2017-05-06 01:29:10,217] WARN Session 0x15bdb5b6dbc0002 for server null, unexpected error, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn:1162)
> java.net.ConnectException: Connection refused
> 	at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
> 	at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
> 	at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)
> 	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)
> [2017-05-06 01:29:10,571] WARN Session 0x15bdb5b6dbc0001 for server null, unexpected error, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn:1162)
> java.net.ConnectException: Connection refused
> 	at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
> 	at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
> 	at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)
> 	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)
> [2017-05-06 01:29:11,611] WARN Session 0x15bdb5b6dbc0002 for server null, unexpected error, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn:1162)
> java.net.ConnectException: Connection refused
> 	at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
> 	at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
> 	at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)
> 	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)
> [2017-05-06 01:29:12,114] WARN Session 0x15bdb5b6dbc0001 for server null, unexpected error, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn:1162)
> java.net.ConnectException: Connection refused
> 	at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
> 	at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
> 	at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)
> 	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)
> [2017-05-06 01:29:13,442] WARN Session 0x15bdb5b6dbc0001 for server null, unexpected error, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn:1162)
> java.net.ConnectException: Connection refused
> 	at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
> 	at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
> 	at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)
> 	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)
> [2017-05-06 01:29:13,469] WARN Session 0x15bdb5b6dbc0002 for server null, unexpected error, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn:1162)
> java.net.ConnectException: Connection refused
> 	at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
> 	at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
> 	at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)
> 	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)
> [2017-05-06 01:29:14,650] WARN Session 0x15bdb5b6dbc0001 for server null, unexpected error, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn:1162)
> java.net.ConnectException: Connection refused
> 	at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
> 	at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
> 	at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)
> 	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)
> [2017-05-06 01:29:15,209] ERROR [ReplicaFetcherThread-0-0]: Error for partition [__consumer_offsets,13] to broker 0:org.apache.kafka.common.errors.NotLeaderForPartitionException: This server is not the leader for that topic-partition. (kafka.server.ReplicaFetcherThread:99)
> [2017-05-06 01:29:15,327] ERROR [ReplicaFetcherThread-0-0]: Error for partition [__consumer_offsets,41] to broker 0:org.apache.kafka.common.errors.NotLeaderForPartitionException: This server is not the leader for that topic-partition. (kafka.server.ReplicaFetcherThread:99)
> [2017-05-06 01:29:15,412] WARN Session 0x15bdb5b6dbc0002 for server null, unexpected error, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn:1162)
> java.net.ConnectException: Connection refused
> 	at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
> 	at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
> 	at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)
> 	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)
> [2017-05-06 01:29:15,438] ERROR [ReplicaFetcherThread-0-0]: Error for partition [__consumer_offsets,35] to broker 0:org.apache.kafka.common.errors.NotLeaderForPartitionException: This server is not the leader for that topic-partition. (kafka.server.ReplicaFetcherThread:99)
> [2017-05-06 01:29:15,464] ERROR [ReplicaFetcherThread-0-0]: Error for partition [__consumer_offsets,3] to broker 0:org.apache.kafka.common.errors.NotLeaderForPartitionException: This server is not the leader for that topic-partition. (kafka.server.ReplicaFetcherThread:99)
> [2017-05-06 01:29:16,490] WARN Session 0x15bdb5b6dbc0001 for server null, unexpected error, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn:1162)
> java.net.ConnectException: Connection refused
> 	at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
> 	at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
> 	at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)
> 	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)
> [2017-05-06 01:29:17,416] WARN Session 0x15bdb5b6dbc0002 for server null, unexpected error, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn:1162)
> java.net.ConnectException: Connection refused
> 	at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
> 	at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
> 	at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)
> 	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)
> [2017-05-06 01:29:18,346] WARN Session 0x15bdb5b6dbc0001 for server null, unexpected error, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn:1162)
> java.net.ConnectException: Connection refused
> 	at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
> 	at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
> 	at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)
> 	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)
> [2017-05-06 01:29:18,795] WARN Session 0x15bdb5b6dbc0002 for server null, unexpected error, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn:1162)
> java.net.ConnectException: Connection refused
> 	at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
> 	at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
> 	at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)
> 	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)
> [2017-05-06 01:29:19,311] WARN caught end of stream exception (org.apache.zookeeper.server.NIOServerCnxn:368)
> EndOfStreamException: Unable to read additional data from client sessionid 0x15bdb5fb0780001, likely client has closed socket
> 	at org.apache.zookeeper.server.NIOServerCnxn.doIO(NIOServerCnxn.java:239)
> 	at org.apache.zookeeper.server.NIOServerCnxnFactory.run(NIOServerCnxnFactory.java:203)
> 	at java.lang.Thread.run(Thread.java:745)
> [2017-05-06 01:29:19,572] ERROR [Controller 1]: Error while electing or becoming controller on broker 1 (kafka.controller.KafkaController:105)
> kafka.common.BrokerEndPointNotAvailableException: End point with security protocol ListenerName(PLAINTEXT) not found for broker 1
> 	at kafka.cluster.Broker.$anonfun$getBrokerEndPoint$1(Broker.scala:178)
> 	at scala.collection.MapLike.getOrElse(MapLike.scala:128)
> 	at scala.collection.MapLike.getOrElse$(MapLike.scala:126)
> 	at scala.collection.AbstractMap.getOrElse(Map.scala:59)
> 	at kafka.cluster.Broker.getBrokerEndPoint(Broker.scala:178)
> 	at kafka.controller.ControllerChannelManager.addNewBroker(ControllerChannelManager.scala:92)
> 	at kafka.controller.ControllerChannelManager.$anonfun$new$1(ControllerChannelManager.scala:46)
> 	at kafka.controller.ControllerChannelManager.$anonfun$new$1$adapted(ControllerChannelManager.scala:46)
> 	at scala.collection.immutable.Set$Set1.foreach(Set.scala:95)
> 	at kafka.controller.ControllerChannelManager.<init>(ControllerChannelManager.scala:46)
> 	at kafka.controller.KafkaController.startChannelManager(KafkaController.scala:724)
> 	at kafka.controller.KafkaController.initializeControllerContext(KafkaController.scala:659)
> 	at kafka.controller.KafkaController.onControllerFailover(KafkaController.scala:248)
> 	at kafka.controller.KafkaController.elect(KafkaController.scala:1558)
> 	at kafka.controller.KafkaController$Reelect$.process(KafkaController.scala:1505)
> 	at kafka.controller.KafkaController$ControllerEventThread.doWork(KafkaController.scala:1147)
> 	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:64)
> [2017-05-06 01:29:19,832] ERROR [Controller 0]: Error while electing or becoming controller on broker 0 (kafka.controller.KafkaController:105)
> kafka.common.BrokerEndPointNotAvailableException: End point with security protocol ListenerName(PLAINTEXT) not found for broker 1
> 	at kafka.cluster.Broker.$anonfun$getBrokerEndPoint$1(Broker.scala:178)
> 	at scala.collection.MapLike.getOrElse(MapLike.scala:128)
> 	at scala.collection.MapLike.getOrElse$(MapLike.scala:126)
> 	at scala.collection.AbstractMap.getOrElse(Map.scala:59)
> 	at kafka.cluster.Broker.getBrokerEndPoint(Broker.scala:178)
> 	at kafka.controller.ControllerChannelManager.addNewBroker(ControllerChannelManager.scala:92)
> 	at kafka.controller.ControllerChannelManager.$anonfun$new$1(ControllerChannelManager.scala:46)
> 	at kafka.controller.ControllerChannelManager.$anonfun$new$1$adapted(ControllerChannelManager.scala:46)
> 	at scala.collection.immutable.Set$Set1.foreach(Set.scala:95)
> 	at kafka.controller.ControllerChannelManager.<init>(ControllerChannelManager.scala:46)
> 	at kafka.controller.KafkaController.startChannelManager(KafkaController.scala:724)
> 	at kafka.controller.KafkaController.initializeControllerContext(KafkaController.scala:659)
> 	at kafka.controller.KafkaController.onControllerFailover(KafkaController.scala:248)
> 	at kafka.controller.KafkaController.elect(KafkaController.scala:1558)
> 	at kafka.controller.KafkaController$Reelect$.process(KafkaController.scala:1505)
> 	at kafka.controller.KafkaController$ControllerEventThread.doWork(KafkaController.scala:1147)
> 	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:64)
> [2017-05-06 01:29:20,021] ERROR [Controller 1]: Error while electing or becoming controller on broker 1 (kafka.controller.KafkaController:105)
> kafka.common.BrokerEndPointNotAvailableException: End point with security protocol ListenerName(PLAINTEXT) not found for broker 1
> 	at kafka.cluster.Broker.$anonfun$getBrokerEndPoint$1(Broker.scala:178)
> 	at scala.collection.MapLike.getOrElse(MapLike.scala:128)
> 	at scala.collection.MapLike.getOrElse$(MapLike.scala:126)
> 	at scala.collection.AbstractMap.getOrElse(Map.scala:59)
> 	at kafka.cluster.Broker.getBrokerEndPoint(Broker.scala:178)
> 	at kafka.controller.ControllerChannelManager.addNewBroker(ControllerChannelManager.scala:92)
> 	at kafka.controller.ControllerChannelManager.$anonfun$new$1(ControllerChannelManager.scala:46)
> 	at kafka.controller.ControllerChannelManager.$anonfun$new$1$adapted(ControllerChannelManager.scala:46)
> 	at scala.collection.immutable.Set$Set1.foreach(Set.scala:95)
> 	at kafka.controller.ControllerChannelManager.<init>(ControllerChannelManager.scala:46)
> 	at kafka.controller.KafkaController.startChannelManager(KafkaController.scala:724)
> 	at kafka.controller.KafkaController.initializeControllerContext(KafkaController.scala:659)
> 	at kafka.controller.KafkaController.onControllerFailover(KafkaController.scala:248)
> 	at kafka.controller.KafkaController.elect(KafkaController.scala:1558)
> 	at kafka.controller.KafkaController$Reelect$.process(KafkaController.scala:1505)
> 	at kafka.controller.KafkaController$ControllerEventThread.doWork(KafkaController.scala:1147)
> 	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:64)
> [2017-05-06 01:29:20,045] WARN Session 0x15bdb5b6dbc0002 for server null, unexpected error, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn:1162)
> java.net.ConnectException: Connection refused
> 	at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
> 	at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
> 	at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)
> 	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)
> [2017-05-06 01:29:20,386] WARN Session 0x15bdb5b6dbc0001 for server null, unexpected error, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn:1162)
> java.net.ConnectException: Connection refused
> 	at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
> 	at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
> 	at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)
> 	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)
> [2017-05-06 01:29:21,871] WARN Session 0x15bdb5b6dbc0002 for server null, unexpected error, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn:1162)
> java.net.ConnectException: Connection refused
> 	at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
> 	at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
> 	at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)
> 	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)
> [2017-05-06 01:29:22,091] WARN Session 0x15bdb5b6dbc0001 for server null, unexpected error, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn:1162)
> java.net.ConnectException: Connection refused
> 	at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
> 	at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
> 	at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)
> 	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)
> [2017-05-06 01:29:22,181] ERROR ZKShutdownHandler is not registered, so ZooKeeper server won't take any action on ERROR or SHUTDOWN server state changes (org.apache.zookeeper.server.ZooKeeperServer:472)
> [2017-05-06 01:29:22,181] WARN Exception causing close of session 0x15bdb5fb0780004 due to java.io.IOException: ZooKeeperServer not running (org.apache.zookeeper.server.NIOServerCnxn:373)
> {code}



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

Mime
View raw message