kafka創建topic報錯ERROR org.apache.kafka.common.errors.InvalidReplicationFactorException
在kafka創建topic中輸入以下命令
bin/kafka-topics.sh --zookeeper node01:2181 --create --replication-factor 3 --partitions 1 --topic first
報錯
ERROR org.apache.kafka.common.errors.InvalidReplicationFactorException: Replication factor: 3 larger than available brokers: 0.
(kafka.admin.TopicCommand$)
出現上述的原因是原因是kafka的zookeeper.connect設置為:
zookeeper.connect=node01:2181,node02:2181,node03:2181/kafka
解決辦法:zookeeper后面要加上/kafka
bin/kafka-topics.sh --zookeeper node01:2181/kafka --create --replication-factor 3 --partitions 1 --topic first
以前的沒有添加這個/kafka,是因為zookeeper.connect中沒有配置