Hello Does anyone know why when I add "rebalance()" to my .map steps is adding a lot of latency rather than not having rebalance.
I have kafka partitions in my topic 44 and 44 flink task manager execution plan looks like this when I add rebalance but it is adding a lot of latency kafka-src -> rebalance -> step1 -> rebalance ->step2->rebalance -> kafka-sink Thank you regards
