执行kafka-topics.sh创建Kafka topic时报Broker may not be available错误
错误成因
- 核心错误点:
--bootstrap-server参数需要填写Kafka Broker的服务地址,默认端口为9092,但你填写的2181是ZooKeeper的默认监听端口,AdminClient尝试连接2181端口获取Broker服务自然失败,因此抛出Broker may not be available的警告。 - 补充背景:Kafka 2.2+版本官方已废弃通过
--zookeeper参数直连ZK执行topic管理操作的方式,统一要求使用--bootstrap-server连接Broker操作,很多新手容易混淆两类参数对应的端口配置。
报错截图:
修复步骤
- 先确认Kafka Broker服务已正常启动,未修改端口的前提下默认监听9092端口,若自定义过端口则替换为对应自定义端口即可
- 执行修正后的创建topic命令:
./bin/kafka-topics.sh --bootstrap-server localhost:9092 --create --topic test --partitions 3 --replication-factor 1
- 若执行后仍有报错,可先通过
nc -zv localhost 9092命令校验9092端口是否可正常连通,也可以查看Kafka服务日志确认Broker启动无异常。
内容的提问来源于stack exchange,提问作者Michail Lamprakis
相关产品推荐
相关产品推荐

