kafka 3.1 版本创建 topic 时 --zookeeper 的问题

kafka 3.1 版本创建 topic 时 --zookeeper 的问题

我使用的kafka版本是3.1,使用 kafka-topics.sh 脚本创建 topic 时,官方文档建议使用 --bootstrap-server 代替 --zookeeper ,但是为什么要使用9092端口呢?我的zk配置的确实是2181端口


https://img1.sycdn.imooc.com//climg/622c36cb099ebbab00000000.jpg


如果使用 --zookeeper 的话,会报错不识别该参数

[root@bigdata01 kafka_2.12-3.1.0]# bin/kafka-topics.sh --create --zookeeper localhost:2181  --partitions 2 --replication-factor 2 --topic hello
Exception in thread "main" joptsimple.UnrecognizedOptionException: zookeeper is not a recognized option
        at joptsimple.OptionException.unrecognizedOption(OptionException.java:108)
        at joptsimple.OptionParser.handleLongOptionToken(OptionParser.java:510)
        at joptsimple.OptionParserState$2.handleArgument(OptionParserState.java:56)
        at joptsimple.OptionParser.parse(OptionParser.java:396)
        at kafka.admin.TopicCommand$TopicCommandOptions.<init>(TopicCommand.scala:567)
        at kafka.admin.TopicCommand$.main(TopicCommand.scala:47)
        at kafka.admin.TopicCommand.main(TopicCommand.scala)



补充:

我看到这个 9092 端口其实是 kafka 自己占用的

https://img1.sycdn.imooc.com//climg/622c38da09cd141422641314.jpg

正在回答 回答被采纳积分+1

登陆购买课程后可参与讨论,去登陆

1回答
徐老师 2022-03-12 14:41:18

1:9092端口是Kafka自己的,这个从Kafka0.x版本开始一直到现在最新的3.x版本都是这个。

2:kafka3.x版本中移除了Zookeeper,自己实现了之前依赖于Zookeeper的功能。3.x版本是去年9月份新发布的,目前企业中常见的还是1.x和2.x。

建议在学习阶段用课程中的版本,因为不同版本之间有的会有一些区别。

问题已解决,确定采纳
还有疑问,暂不采纳

恭喜解决一个难题,获得1积分~

来为老师/同学的回答评分吧

0 星
请稍等 ...
意见反馈 帮助中心 APP下载
官方微信

在线咨询

领取优惠

免费试听

领取大纲

扫描二维码,添加
你的专属老师