天天看點

kafka建立topic報錯

kafka執行如下建立topic的語句:

[root@node01 kafka_2.11-1.0.0]# bin/kafka-topics.sh --create --topic streaming-test --replication-factor 1 --partitions 3 --zookeeper node01:2181,node02:2181,node03:2181

Error while executing topic command : Replication factor: 1 larger than available brokers: 0.

報錯:[2019-10-15 20:23:25,461] ERROR org.apache.kafka.common.errors.InvalidReplicationFactorException: Replication factor: 1 larger than available brokers: 0.

原因:broker的配置檔案server.properties中的配置項zookeeper.connect指定了kafka的zookeeper的根目錄(zookeeper.connect=node01:2181,node02:2181,node03:2181/kafka)

解決方法:指令行參數“--zookeeper”的值也需要帶上根目錄,如下:

bin/kafka-topics.sh --create --topic streaming-test --replication-factor 1 --partitions 3 --zookeeper node01:2181,node02:2181,node03:2181/kafka