Hi all, I just wonder can Beam allow to set parallelism for each operator (PTransform) separately? Flink provides such feature.
The usecase I have is the source is kafka topics, which has less partitions, while we have heavy PTransform and would like to scale it with more parallelism. Thanks a lot! Eleanore