flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "gaofeilong198810@163.com" <gaofeilong198...@163.com>
Subject 回复: 如何使用forward方式向kafka中生产数据
Date Wed, 04 Sep 2019 10:21:05 GMT

有大佬确认过吗


--
高飞龙
手机 +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
Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message