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