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Ā 

Reply via email to