You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by "gaofeilong198810@163.com" <ga...@163.com> on 2019/09/02 14:56:09 UTC
如何使用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)
--
高飞龙
gaofeilong198810@163.com
回复: 如何使用forward方式向kafka中生产数据
Posted by "gaofeilong198810@163.com" <ga...@163.com>.
有大佬确认过吗
--
高飞龙
手机 +86 18710107193
gaofeilong198810@163.com
发件人： gaofeilong198810@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)
--
高飞龙
gaofeilong198810@163.com