可以的，提供一个思路，读取了kafka的数据后，直接输出原生的字节流后，接一层map算子做序列化相关工作，map算子的并发度你可以自己控制，这样kafka拉取就不会是瓶颈，大量的计算工作放到了map中，而map的并发度是可以自己控制的
Caizhi Weng <tsreape...@gmail.com> 于2022年1月11日周二 11:11写道： > Hi！ > > 可以设置 parallelism.default 为需要的并发数。 > > Jeff <zilong0...@126.com> 于2022年1月9日周日 19:44写道： > > > 当source为kafka时，最大并发度由kafka分区决定的， 有没有办法在不增加kafka分区情况下提高整个任务的并发度呢? >
