Kafka do poleceń Heca produkuje błąd

Question

bin/kafka-topics.sh --create --topic activityTopic --zookeeper localhost:2181/kafka --partitions 1 --replication-factor 1 

Powyższe polecenie od Kafki produkuje błąd

Error while executing topic command org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /brokers/ids 
org.I0Itec.zkclient.exception.ZkNoNodeException: org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /brokers/ids 
at org.I0Itec.zkclient.exception.ZkException.create(ZkException.java:47) 
at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:685) 
at org.I0Itec.zkclient.ZkClient.getChildren(ZkClient.java:413) 
at org.I0Itec.zkclient.ZkClient.getChildren(ZkClient.java:409) 
at kafka.utils.ZkUtils$.getChildren(ZkUtils.scala:462) 
at kafka.utils.ZkUtils$.getSortedBrokerList(ZkUtils.scala:78) 
at kafka.admin.AdminUtils$.createTopic(AdminUtils.scala:170) 
at kafka.admin.TopicCommand$.createTopic(TopicCommand.scala:93) 
at kafka.admin.TopicCommand$.main(TopicCommand.scala:55) 
at kafka.admin.TopicCommand.main(TopicCommand.scala) 
Caused by: org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /brokers/ids 
at org.apache.zookeeper.KeeperException.create(KeeperException.java:111) 
at org.apache.zookeeper.KeeperException.create(KeeperException.java:51) 
at org.apache.zookeeper.ZooKeeper.getChildren(ZooKeeper.java:1472) 
at org.apache.zookeeper.ZooKeeper.getChildren(ZooKeeper.java:1500) 
at org.I0Itec.zkclient.ZkConnection.getChildren(ZkConnection.java:99) 
at org.I0Itec.zkclient.ZkClient$2.call(ZkClient.java:416) 
at org.I0Itec.zkclient.ZkClient$2.call(ZkClient.java:413) 
at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:675) 

Każdy pomysł?

Answer 1

podczas tworzenia tematu powinien być zookeeper url z opcją --zookeeper. Powinien działać następujący wiersz, jeśli działa kafle zookeeper &.

--zookeeper localhost:2181 

This link describes how to create a topic. Można również sprawdzić brak dostępnych identyfikatorów w Heca CLI. ./zkCli.sh & następnie ls /brokers/ids. W dzierżawie powinien zostać wyświetlony jeden identyfikator pośrednika.

Answer 2

W moim przypadku problem polegał na tym, że Określiłem nieistniejący chroot kafka.

Odkryłem, że nasz zespół ops firmy skonfigurował kafka chroot jako purple-elephants i skonfigurował utworzenie tego chroota, które ma być zapewnione w restarcie kafka.

Najpierw wydał sudo service kafka restart i dziennika wynika, że ​​chroot został stworzony:

Ensuring chroot '/purple-elephants' exists 
Starting Kafka server.        

Potem po prostu wydane:

bin/kafka-topics.sh --create --topic activityTopic --zookeeper localhost:2181/purple-elephants --partitions 1 --replication-factor 1 

Answer 3

Spróbuj usunąć/Kafka, jak polecenie jest

bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 3 --topic Falcon 

Jeśli nadal występuje, to upewnij się, że ścieżka w zookeeper.properties z

dataDir(default is /tmp/zookeeper) 

i ścieżka w server.properties z

log.dirs(default is /tmp/kafka-logs) 

Answer 4

w moim przypadku zacząłem tylko Zookeeper i zapomniał zaczynając serwer Kafki. Uruchomiłem także serwer kafka, a następnie utworzyłem temat. Polecenie działało dobrze.