Hello We are testing a simple use case where we read from kafka -> process and write to kafka.
I have set parallelism of the job to 3 and parallelism for the process function to 6. When I looked at the job graph in the Flink UI noticed that between the source and process function a rebalance step was introduced. Is this expected ? I was expecting some instances of process tasks to be idle i.e. 3 tasks to be idle. Thanks Suraj
