如何使用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)



--
高飞龙

[hidden email]

有大佬确认过吗


--
高飞龙
手机 [phone]
[hidden email]
 
发件人： [hidden email]
发送时间： 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)



--
高飞龙

[hidden email]