kafka 3.1 版本创建 topic 时 --zookeeper 的问题
我使用的kafka版本是3.1,使用 kafka-topics.sh 脚本创建 topic 时,官方文档建议使用 --bootstrap-server 代替 --zookeeper ,但是为什么要使用9092端口呢?我的zk配置的确实是2181端口
如果使用 --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 自己占用的
16
收起
正在回答 回答被采纳积分+1
1回答
恭喜解决一个难题,获得1积分~
来为老师/同学的回答评分吧
0 星