{"action":"created","issue":{"url":"https://api.github.com/repos/dibbhatt/kafka-spark-consumer/issues/16","repository_url":"https://api.github.com/repos/dibbhatt/kafka-spark-consumer","labels_url":"https://api.github.com/repos/dibbhatt/kafka-spark-consumer/issues/16/labels{/name}","comments_url":"https://api.github.com/repos/dibbhatt/kafka-spark-consumer/issues/16/comments","events_url":"https://api.github.com/repos/dibbhatt/kafka-spark-consumer/issues/16/events","html_url":"https://github.com/dibbhatt/kafka-spark-consumer/issues/16","id":73224250,"number":16,"title":"org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /brokers/topics/load/partitions","user":{"login":"justinjoseph89","id":10243115,"avatar_url":"https://avatars.githubusercontent.com/u/10243115?v=3","gravatar_id":"","url":"https://api.github.com/users/justinjoseph89","html_url":"https://github.com/justinjoseph89","followers_url":"https://api.github.com/users/justinjoseph89/followers","following_url":"https://api.github.com/users/justinjoseph89/following{/other_user}","gists_url":"https://api.github.com/users/justinjoseph89/gists{/gist_id}","starred_url":"https://api.github.com/users/justinjoseph89/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/justinjoseph89/subscriptions","organizations_url":"https://api.github.com/users/justinjoseph89/orgs","repos_url":"https://api.github.com/users/justinjoseph89/repos","events_url":"https://api.github.com/users/justinjoseph89/events{/privacy}","received_events_url":"https://api.github.com/users/justinjoseph89/received_events","type":"User","site_admin":false},"labels":[],"state":"closed","locked":false,"assignee":null,"assignees":[],"milestone":null,"comments":9,"created_at":"2015-05-05T06:30:52Z","updated_at":"2016-08-24T16:44:35Z","closed_at":"2015-05-05T08:36:17Z","body":"Hi,\r\nI am trying to run the consumer , but getting following error. Any idea why i am getting this?\r\n\r\nINFO : org.apache.curator.framework.state.ConnectionStateManager - State change: CONNECTED\r\nException in thread \"main\" java.lang.RuntimeException: org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /brokers/topics/load/partitions\r\n\tat consumer.kafka.ReceiverLauncher.getNumPartitions(ReceiverLauncher.java:109)\r\n\tat consumer.kafka.ReceiverLauncher.createStream(ReceiverLauncher.java:53)\r\n\tat consumer.kafka.ReceiverLauncher.launch(ReceiverLauncher.java:36)\r\n\tat consumer.kafka.client.Consumer.run(Consumer.java:72)\r\n\tat consumer.kafka.client.Consumer.start(Consumer.java:43)\r\n\tat consumer.kafka.client.Consumer.main(Consumer.java:95)\r\nCaused by: org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /brokers/topics/load/partitions\r\n\tat org.apache.zookeeper.KeeperException.create(KeeperException.java:111)\r\n\tat org.apache.zookeeper.KeeperException.create(KeeperException.java:51)\r\n\tat org.apache.zookeeper.ZooKeeper.getChildren(ZooKeeper.java:1590)\r\n\tat org.apache.curator.framework.imps.GetChildrenBuilderImpl$3.call(GetChildrenBuilderImpl.java:214)\r\n\tat org.apache.curator.framework.imps.GetChildrenBuilderImpl$3.call(GetChildrenBuilderImpl.java:203)\r\n\tat org.apache.curator.RetryLoop.callWithRetry(RetryLoop.java:107)\r\n\tat org.apache.curator.framework.imps.GetChildrenBuilderImpl.pathInForeground(GetChildrenBuilderImpl.java:199)\r\n\tat org.apache.curator.framework.imps.GetChildrenBuilderImpl.forPath(GetChildrenBuilderImpl.java:191)\r\n\tat org.apache.curator.framework.imps.GetChildrenBuilderImpl.forPath(GetChildrenBuilderImpl.java:38)\r\n\tat consumer.kafka.ReceiverLauncher.getNumPartitions(ReceiverLauncher.java:105)\r\n\t... 5 more\r\n"},"comment":{"url":"https://api.github.com/repos/dibbhatt/kafka-spark-consumer/issues/comments/242131927","html_url":"https://github.com/dibbhatt/kafka-spark-consumer/issues/16#issuecomment-242131927","issue_url":"https://api.github.com/repos/dibbhatt/kafka-spark-consumer/issues/16","id":242131927,"user":{"login":"darpan7","id":5684961,"avatar_url":"https://avatars.githubusercontent.com/u/5684961?v=3","gravatar_id":"","url":"https://api.github.com/users/darpan7","html_url":"https://github.com/darpan7","followers_url":"https://api.github.com/users/darpan7/followers","following_url":"https://api.github.com/users/darpan7/following{/other_user}","gists_url":"https://api.github.com/users/darpan7/gists{/gist_id}","starred_url":"https://api.github.com/users/darpan7/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/darpan7/subscriptions","organizations_url":"https://api.github.com/users/darpan7/orgs","repos_url":"https://api.github.com/users/darpan7/repos","events_url":"https://api.github.com/users/darpan7/events{/privacy}","received_events_url":"https://api.github.com/users/darpan7/received_events","type":"User","site_admin":false},"created_at":"2016-08-24T16:44:35Z","updated_at":"2016-08-24T16:44:35Z","body":"**Working now**! It was in zkroot. Well, first of all, I was connected to remote zookeeper, so I changed it to local. Second, I removed all the logs (/tmp/kafka-logs/<removed everything> & /zookeeper/data/<removed everything>) and restart the zookeeper. It worked. I believe that its because of the remote zookeeper and over there topic was not created. "}}
{"actor":{"display_login":"darpan7"}}