You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/10/19 09:52:00 UTC
[jira] [Updated] (KAFKA-6061) "ERROR Error while electing or
becoming leader on broker 13 (kafka.server.ZookeeperLeaderElector)
kafka.common.KafkaException: Can't parse json string: null" should print
out information on which zookeeper path contains the null element
[ https://issues.apache.org/jira/browse/KAFKA-6061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Ismael Juma updated KAFKA-6061:
-------------------------------
Fix Version/s: 1.1.0
> "ERROR Error while electing or becoming leader on broker 13 (kafka.server.ZookeeperLeaderElector) kafka.common.KafkaException: Can't parse json string: null" should print out information on which zookeeper path contains the null element
> ---------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
>
> Key: KAFKA-6061
> URL: https://issues.apache.org/jira/browse/KAFKA-6061
> Project: Kafka
> Issue Type: Bug
> Components: zkclient
> Affects Versions: 0.10.2.1
> Reporter: Koelli Mungee
> Labels: newbie
> Fix For: 1.1.0
>
>
> The controller enters a loop with the error as
> {code:java}
> [2017-10-12 21:40:09,532] ERROR Error while electing or becoming leader on broker 13 (kafka.server.ZookeeperLeaderElector)
> kafka.common.KafkaException: Can't parse json string: null
> at kafka.utils.Json$.liftedTree1$1(Json.scala:40)
> at kafka.utils.Json$.parseFull(Json.scala:36)
> at kafka.utils.ZkUtils$$anonfun$getReplicaAssignmentForTopics$1.apply(ZkUtils.scala:684)
> at kafka.utils.ZkUtils$$anonfun$getReplicaAssignmentForTopics$1.apply(ZkUtils.scala:680)
> at scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:59)
> at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:48)
> at kafka.utils.ZkUtils.getReplicaAssignmentForTopics(ZkUtils.scala:680)
> at kafka.controller.KafkaController.initializeControllerContext(KafkaController.scala:736)
> at kafka.controller.KafkaController.onControllerFailover(KafkaController.scala:334)
> at kafka.controller.KafkaController$$anonfun$1.apply$mcV$sp(KafkaController.scala:167)
> at kafka.server.ZookeeperLeaderElector.elect(ZookeeperLeaderElector.scala:84)
> {code}
> A kafka-topics --describe can be issued to figure out which topic partition has the problem. However, this would be easier for the user if the actual zk path with the null or malformed entry would be printed out.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)