Re: Flink Kafka Source rebalancing - 1.14.2

2023-05-09 Thread Madan D via user
Hello Shammon/Team, We are using same Flink version which is 1.14.2 but only change is earlier we were using Flink Kafka Consumer not we are moving with Kafka Source. I dont see any difference in Job planner but I see Kafka source is introducing more latency while performing Flinka Kafka consum

Re: Flink Kafka Source rebalancing - 1.14.2

2023-05-09 Thread Shammon FY
Hi Madan, Could you give the old and new versions of flink and provide the job plan? I think it will help community to find the root cause Best, Shammon FY On Wed, May 10, 2023 at 2:04 AM Madan D via user wrote: > Hello Team, > > We have been using Flink Kafka consumer and recently we have bee

Flink Kafka Source rebalancing - 1.14.2

2023-05-09 Thread Madan D via user
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 m