有大佬确认过吗
-- 高飞龙 手机 +86 18710107193 gaofeilong198...@163.com 发件人： gaofeilong198...@163.com 发送时间： 2019-09-02 22:56 收件人： user-zh 主题： 如何使用forward方式向kafka中生产数据 我的kafka有10个分区，现在我希望使用flink程序的forward的方式而不是rebalance的方式向kafka中生产数据，那么是应该用以下哪种方式呢？ ds.map(line => someFunction).setParallelism(10).addSink(myKafkaProducer) or ds.map(line => someFunction).addSink(myKafkaProducer).setParallelism(10) -- 高飞龙 gaofeilong198...@163.com
