Hi, Let's say I have flink Kafka consumer read from 3 topics , [ T-1 ,T-2,T-3 ] .
- T1 and T2 are having partitions equal to 100 - T3 is having partitions equal to 60 - Flink Task (parallelism is 50) How flink will prioritize Kafka topic ? If T-3 has more lag than other topics will flink give higher priority to T-3 ? Thanks and Regards Sohi -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
