Created
December 8, 2016 17:35
-
-
Save jfoy/765e45b5d4d5d84baecec68acbf41b7c to your computer and use it in GitHub Desktop.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Dec 08 17:32:06 kafka3 docker[9517]: java.lang.IllegalArgumentException: requirement failed | |
Dec 08 17:32:06 kafka3 docker[9517]: at scala.Predef$.require(Predef.scala:212) | |
Dec 08 17:32:06 kafka3 docker[9517]: at kafka.server.DynamicConfigManager$ConfigChangedNotificationHandler$.processNotification(DynamicConfigManager.scala:90) | |
Dec 08 17:32:06 kafka3 docker[9517]: at kafka.common.ZkNodeChangeNotificationListener$$anonfun$kafka$common$ZkNodeChangeNotificationListener$$processNotifications$2$$anonfun$apply$2.apply(ZkNodeChangeNotificationListener.scala:95) | |
Dec 08 17:32:06 kafka3 docker[9517]: at kafka.common.ZkNodeChangeNotificationListener$$anonfun$kafka$common$ZkNodeChangeNotificationListener$$processNotifications$2$$anonfun$apply$2.apply(ZkNodeChangeNotificationListener.scala:95) | |
Dec 08 17:32:06 kafka3 docker[9517]: at scala.Option.map(Option.scala:146) | |
Dec 08 17:32:06 kafka3 docker[9517]: at kafka.common.ZkNodeChangeNotificationListener$$anonfun$kafka$common$ZkNodeChangeNotificationListener$$processNotifications$2.apply(ZkNodeChangeNotificationListener.scala:95) | |
Dec 08 17:32:06 kafka3 docker[9517]: at kafka.common.ZkNodeChangeNotificationListener$$anonfun$kafka$common$ZkNodeChangeNotificationListener$$processNotifications$2.apply(ZkNodeChangeNotificationListener.scala:90) | |
Dec 08 17:32:06 kafka3 docker[9517]: at scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:59) | |
Dec 08 17:32:06 kafka3 docker[9517]: at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:48) | |
Dec 08 17:32:06 kafka3 docker[9517]: at kafka.common.ZkNodeChangeNotificationListener.kafka$common$ZkNodeChangeNotificationListener$$processNotifications(ZkNodeChangeNotificationListener.scala:90) | |
Dec 08 17:32:06 kafka3 docker[9517]: at kafka.common.ZkNodeChangeNotificationListener.processAllNotifications(ZkNodeChangeNotificationListener.scala:79) | |
Dec 08 17:32:06 kafka3 docker[9517]: at kafka.common.ZkNodeChangeNotificationListener.init(ZkNodeChangeNotificationListener.scala:67) | |
Dec 08 17:32:06 kafka3 docker[9517]: at kafka.server.DynamicConfigManager.startup(DynamicConfigManager.scala:122) | |
Dec 08 17:32:06 kafka3 docker[9517]: at kafka.server.KafkaServer.startup(KafkaServer.scala:233) | |
Dec 08 17:32:06 kafka3 docker[9517]: at kafka.server.KafkaServerStartable.startup(KafkaServerStartable.scala:37) | |
Dec 08 17:32:06 kafka3 docker[9517]: at kafka.Kafka$.main(Kafka.scala:67) | |
Dec 08 17:32:06 kafka3 docker[9517]: at kafka.Kafka.main(Kafka.scala) | |
Dec 08 17:32:06 kafka3 docker[9517]: [2016-12-08 17:32:06,307] INFO [Kafka Server 3], shutting down (kafka.server.KafkaServer) | |
Dec 08 17:32:06 kafka3 docker[9517]: [2016-12-08 17:32:06,309] INFO [Socket Server on Broker 3], Shutting down (kafka.network.SocketServer) | |
Dec 08 17:32:06 kafka3 docker[9517]: [2016-12-08 17:32:06,317] ERROR [KafkaApi-3] Error when handling request {topics=[stg.json.topicC]} (kafka.server.KafkaApis) | |
Dec 08 17:32:06 kafka3 docker[9517]: kafka.admin.AdminOperationException: replication factor: 1 larger than available brokers: 0 | |
Dec 08 17:32:06 kafka3 docker[9517]: at kafka.admin.AdminUtils$.assignReplicasToBrokers(AdminUtils.scala:117) | |
Dec 08 17:32:06 kafka3 docker[9517]: at kafka.admin.AdminUtils$.createTopic(AdminUtils.scala:403) | |
Dec 08 17:32:06 kafka3 docker[9517]: at kafka.server.KafkaApis.kafka$server$KafkaApis$$createTopic(KafkaApis.scala:629) | |
Dec 08 17:32:06 kafka3 docker[9517]: at kafka.server.KafkaApis$$anonfun$29.apply(KafkaApis.scala:670) | |
Dec 08 17:32:06 kafka3 docker[9517]: at kafka.server.KafkaApis$$anonfun$29.apply(KafkaApis.scala:666) | |
Dec 08 17:32:06 kafka3 docker[9517]: at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234) | |
Dec 08 17:32:06 kafka3 docker[9517]: at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234) | |
Dec 08 17:32:06 kafka3 docker[9517]: at scala.collection.immutable.Set$Set1.foreach(Set.scala:94) | |
Dec 08 17:32:06 kafka3 docker[9517]: at scala.collection.TraversableLike$class.map(TraversableLike.scala:234) | |
Dec 08 17:32:06 kafka3 docker[9517]: at scala.collection.AbstractSet.scala$collection$SetLike$$super$map(Set.scala:47) | |
Dec 08 17:32:06 kafka3 docker[9517]: at scala.collection.SetLike$class.map(SetLike.scala:92) | |
Dec 08 17:32:06 kafka3 docker[9517]: at scala.collection.AbstractSet.map(Set.scala:47) | |
Dec 08 17:32:06 kafka3 docker[9517]: at kafka.server.KafkaApis.getTopicMetadata(KafkaApis.scala:666) | |
Dec 08 17:32:06 kafka3 docker[9517]: at kafka.server.KafkaApis.handleTopicMetadataRequest(KafkaApis.scala:727) | |
Dec 08 17:32:06 kafka3 docker[9517]: at kafka.server.KafkaApis.handle(KafkaApis.scala:79) | |
Dec 08 17:32:06 kafka3 docker[9517]: at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:60) | |
Dec 08 17:32:06 kafka3 docker[9517]: at java.lang.Thread.run(Thread.java:745) | |
Dec 08 17:32:06 kafka3 docker[9517]: [2016-12-08 17:32:06,318] ERROR [KafkaApi-3] Error when handling request {topics=[prod.json.topicA]} (kafka.server.KafkaApis) | |
Dec 08 17:32:06 kafka3 docker[9517]: kafka.admin.AdminOperationException: replication factor: 1 larger than available brokers: 0 | |
Dec 08 17:32:06 kafka3 docker[9517]: at kafka.admin.AdminUtils$.assignReplicasToBrokers(AdminUtils.scala:117) | |
Dec 08 17:32:06 kafka3 docker[9517]: at kafka.admin.AdminUtils$.createTopic(AdminUtils.scala:403) | |
Dec 08 17:32:06 kafka3 docker[9517]: at kafka.server.KafkaApis.kafka$server$KafkaApis$$createTopic(KafkaApis.scala:629) | |
Dec 08 17:32:06 kafka3 docker[9517]: at kafka.server.KafkaApis$$anonfun$29.apply(KafkaApis.scala:670) | |
Dec 08 17:32:06 kafka3 docker[9517]: at kafka.server.KafkaApis$$anonfun$29.apply(KafkaApis.scala:666) | |
Dec 08 17:32:06 kafka3 docker[9517]: at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234) | |
Dec 08 17:32:06 kafka3 docker[9517]: at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234) | |
Dec 08 17:32:06 kafka3 docker[9517]: at scala.collection.immutable.Set$Set1.foreach(Set.scala:94) | |
Dec 08 17:32:06 kafka3 docker[9517]: at scala.collection.TraversableLike$class.map(TraversableLike.scala:234) | |
Dec 08 17:32:06 kafka3 docker[9517]: at scala.collection.AbstractSet.scala$collection$SetLike$$super$map(Set.scala:47) | |
Dec 08 17:32:06 kafka3 docker[9517]: at scala.collection.SetLike$class.map(SetLike.scala:92) | |
Dec 08 17:32:06 kafka3 docker[9517]: at scala.collection.AbstractSet.map(Set.scala:47) | |
Dec 08 17:32:06 kafka3 docker[9517]: at kafka.server.KafkaApis.getTopicMetadata(KafkaApis.scala:666) | |
Dec 08 17:32:06 kafka3 docker[9517]: at kafka.server.KafkaApis.handleTopicMetadataRequest(KafkaApis.scala:727) | |
Dec 08 17:32:06 kafka3 docker[9517]: at kafka.server.KafkaApis.handle(KafkaApis.scala:79) | |
Dec 08 17:32:06 kafka3 docker[9517]: at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:60) | |
Dec 08 17:32:06 kafka3 docker[9517]: at java.lang.Thread.run(Thread.java:745) | |
Dec 08 17:32:06 kafka3 docker[9517]: [2016-12-08 17:32:06,318] ERROR [KafkaApi-3] Error when handling request {topics=[prod.json.topicB]} (kafka.server.KafkaApis) | |
Dec 08 17:32:06 kafka3 docker[9517]: kafka.admin.AdminOperationException: replication factor: 1 larger than available brokers: 0 | |
Dec 08 17:32:06 kafka3 docker[9517]: at kafka.admin.AdminUtils$.assignReplicasToBrokers(AdminUtils.scala:117) | |
Dec 08 17:32:06 kafka3 docker[9517]: at kafka.admin.AdminUtils$.createTopic(AdminUtils.scala:403) | |
Dec 08 17:32:06 kafka3 docker[9517]: at kafka.server.KafkaApis.kafka$server$KafkaApis$$createTopic(KafkaApis.scala:629) | |
Dec 08 17:32:06 kafka3 docker[9517]: at kafka.server.KafkaApis$$anonfun$29.apply(KafkaApis.scala:670) | |
Dec 08 17:32:06 kafka3 docker[9517]: at kafka.server.KafkaApis$$anonfun$29.apply(KafkaApis.scala:666) | |
Dec 08 17:32:06 kafka3 docker[9517]: at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234) | |
Dec 08 17:32:06 kafka3 docker[9517]: at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234) | |
Dec 08 17:32:06 kafka3 docker[9517]: at scala.collection.immutable.Set$Set1.foreach(Set.scala:94) | |
Dec 08 17:32:06 kafka3 docker[9517]: at scala.collection.TraversableLike$class.map(TraversableLike.scala:234) | |
Dec 08 17:32:06 kafka3 docker[9517]: at scala.collection.AbstractSet.scala$collection$SetLike$$super$map(Set.scala:47) | |
Dec 08 17:32:06 kafka3 docker[9517]: at scala.collection.SetLike$class.map(SetLike.scala:92) | |
Dec 08 17:32:06 kafka3 docker[9517]: at scala.collection.AbstractSet.map(Set.scala:47) | |
Dec 08 17:32:06 kafka3 docker[9517]: at kafka.server.KafkaApis.getTopicMetadata(KafkaApis.scala:666) | |
Dec 08 17:32:06 kafka3 docker[9517]: at kafka.server.KafkaApis.handleTopicMetadataRequest(KafkaApis.scala:727) | |
Dec 08 17:32:06 kafka3 docker[9517]: at kafka.server.KafkaApis.handle(KafkaApis.scala:79) | |
Dec 08 17:32:06 kafka3 docker[9517]: at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:60) | |
Dec 08 17:32:06 kafka3 docker[9517]: at java.lang.Thread.run(Thread.java:745) | |
Dec 08 17:32:06 kafka3 docker[9517]: [2016-12-08 17:32:06,320] INFO [Socket Server on Broker 3], Shutdown completed (kafka.network.SocketServer) | |
Dec 08 17:32:06 kafka3 docker[9517]: [2016-12-08 17:32:06,320] INFO [Kafka Request Handler on Broker 3], shutting down (kafka.server.KafkaRequestHandlerPool) | |
Dec 08 17:32:06 kafka3 docker[9517]: [2016-12-08 17:32:06,322] INFO [Kafka Request Handler on Broker 3], shut down completely (kafka.server.Kafk |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Just remove zNodes under '/config' path in Zookeeper. Looks like you have several Kafka server version pointing to the same Zookeeper instance.