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



Reply via email to