Kafka 报错 InvalidReplicationFactorException: Replication factor:

报错InvalidReplicationFactorException: Replication factor:1 larger than available brokers原因是kafka的zk中的配置与创建参数对不上打开server.propertiesvim /opt/module/kafka/config/server.properties查看配置zookeeper.connect=had

翁老师的教学团队

8304人浏览 · 2021-09-12 23:58:28

翁老师的教学团队 · 2021-09-12 23:58:28 发布

报错
InvalidReplicationFactorException: Replication factor:
1 larger than available brokers

原因是kafka的zk中的配置与创建参数对不上
打开server.properties
vim /opt/module/kafka/config/server.properties
查看配置
zookeeper.connect=hadoop102:2181,hadoop103:2181,hadoop104:2181/kafka
此时创建主题
bin/kafka-topics.sh --zookeeper hadoop102:2181/kafka --create --replication-factor 3 --partitions 1 --topic first
此处 zookeeper参数值必须与配置的一致