开发者社区 > 大数据与机器学习 > 大数据开发治理DataWorks > 正文

请帮忙看看我的这个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 185 0
1 条回答
写回答
取消 提交回答
  • 我记得是--bootstrap-server ,或者你去看源码3,去看他怎么配置的。此答案整理自钉群“Flink CDC 社区”

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

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

热门讨论

热门文章

相关电子书

更多
低代码开发师(初级)实战教程 立即下载
冬季实战营第三期:MySQL数据库进阶实战 立即下载
阿里巴巴DevOps 最佳实践手册 立即下载