退订
















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

回复