您好:
flink将数据写入kafka【kafka为sink】,当kafka
topic分区数【设置的60】小于设置的并行度【设置的300】时,task是轮询写入这些分区吗,是否会影响写入效率?【是否存在遍历时的耗时情况】。
此时,如果扩大topic的分区数【添加至200,或者直接到300】,写入的效率是否会有明显的提升?
是否有相关的源码可以查看。
期待回复,祝好,谢谢!- flink写kafka时,并行度和分区数的设置问题 chenyu_opensource
- Re: flink写kafka时,并行度和分区数的设置问题 Zhanghao Chen
- Re:flink写kafka时,并行度和分区数的设置问题 熊柱
