做实时数仓，sql怎么保证分topic区有序

[air23]

hi
就是我用
       flink sql 通过ddl读取和写入kafka怎么设置并行度呢？
       flink sql 通过ddl写入kafka怎么自定义分区呢？


这样才能保证提高消费能力。和保证数据有序。 但是好像没有发现再table模式 或者sql 语句上设置  或者做自定义分区。