Hello Team, We have been using Flink Kafka consumer and recently we have been moving to Flink Kafka source to get more advanced features but we have been observing more rebalances right after data consumed and moving to next operator than Flink Kafka consumer.
Can you please let us know what might be causing even though we are using same parallelism in old and new jobs and we are on Flink 1.14.2. Regards,MadanĀ