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