[
https://issues.apache.org/jira/browse/KAFKA-5184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15999371#comment-15999371
]
Ismael Juma commented on KAFKA-5184:
------------------------------------
cc [~baluchicken] [~rsivaram]
> 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é
>
> 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/localh...@example.com tryFirstPass is false useFirstPass is false
> storePass is false clearPass is false
> principal is kafka/localh...@example.com
> Will use keytab
> Commit Succeeded
> [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)
