请帮忙看看我的这个2.2.1-cdh6.3.2的生产者提交的命令行有什么问题?

我想问一下,我的这个2.2.1-cdh6.3.2的生产者提交的命令行是bin/kafka-console-producer.sh --broker-list xxxxxxxx:9092 --topic my-topic,而不是最新的bin/kafka-console-producer.sh --bootstrap-server xxxxxxxxx:9092 --topic my-topic--broker-list,--bootstrap-server 这个命令行有区别,不影响FlinkKafkaProducer的api提交代码吧?20541b2d72fd2eb8eba5e7fadb547b03.png

展开
收起
滴滴滴~ 2023-03-21 12:15:51 199 分享 版权
1 条回答
写回答
取消 提交回答
  • 我记得是--bootstrap-server ,或者你去看源码3,去看他怎么配置的。此答案整理自钉群“Flink CDC 社区”

    2023-03-21 16:36:36
    赞同 展开评论

DataWorks基于MaxCompute/Hologres/EMR/CDP等大数据引擎,为数据仓库/数据湖/湖仓一体等解决方案提供统一的全链路大数据开发治理平台。

收录在圈子:
+ 订阅
还有其他疑问?
咨询AI助理