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