[KAFKA-5184] Transient failure: MultipleListenersWithAdditionalJaasContextTest.testProduceConsume - ASF JIRA

Attach files

Attach Screenshot

Voters

Watch issue

Watchers

Link

Clone

Update Comment Author

Replace String in Comment

Update Comment Visibility

Delete Comments

XML

Word

Printable

JSON

Details

Type: Sub-task
Status: Resolved
Priority: Major
Resolution: Fixed
Affects Version/s: None
Fix Version/s: None
Component/s: None
Labels:
None

Description

https://builds.apache.org/job/kafka-pr-jdk8-scala2.12/3574/testReport/junit/kafka.server/MultipleListenersWithAdditionalJaasContextTest/testProduceConsume/

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)