kafka創建topic報錯ERROR org.apache.kafka.common.errors.InvalidReplicationFactorException


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中沒有配置


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM