在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即可

Logo

为开发者提供学习成长、分享交流、生态实践、资源工具等服务,帮助开发者快速成长。

更多推荐