Kafka 報錯 InvalidReplicationFactorException: Replication factor:

報錯

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參數值必須與配置的一緻