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 --top
·
在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$)
出现上述的问题是原因:
副本因子个数超过可用的borker数量。副本个数是3,brokers数量是0,此时报错的副本数大于broker数量,但是我们的kafka是正常启动的,是因为创建主题时写的kafka配置的zookeeper存放的元数据的路径不对,在node01:2181的路径上没有是没有kafka的配置信息的,就查不到broker数量。
而我在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 node01:2181,node02:2181,node03:2181即可
更多推荐
已为社区贡献2条内容
所有评论(0)