kafka默认分区有序，所以source的并发一般小于等于kafka的partition数，理想状态是1：1 sink的并发一般也是也是和输出topic相关，如果要保证有序，可以按key进行分区， 保证数据均匀可以自定义分区策略，比如roundrobin、shuffle等
> 2020年7月2日 下午6:39，air23 <wangfei23_...@163.com> 写道： > > hi > 就是我用 > flink sql 通过ddl读取和写入kafka怎么设置并行度呢？ > flink sql 通过ddl写入kafka怎么自定义分区呢？ > > > 这样才能保证提高消费能力。和保证数据有序。 但是好像没有发现再table模式 或者sql 语句上设置 或者做自定义分区。 > > > > >
