1、常规任务:Source,Transform,Sink算子都与Kafka分区保持一致 2、计算偏大任务:Source,Sink算子与Kafka分区保持一致,Transform算子可设置成2的n次方,64,128…