Skip to content

Instantly share code, notes, and snippets.

@jfoy
Created December 8, 2016 17:35
Show Gist options
  • Save jfoy/765e45b5d4d5d84baecec68acbf41b7c to your computer and use it in GitHub Desktop.
Save jfoy/765e45b5d4d5d84baecec68acbf41b7c to your computer and use it in GitHub Desktop.
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
@EugeneYushin
Copy link

Just remove zNodes under '/config' path in Zookeeper. Looks like you have several Kafka server version pointing to the same Zookeeper instance.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment