How Flink prioritise read from kafka topics and partitions ?

Posted by sohimankotia on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/How-Flink-prioritise-read-from-kafka-topics-and-partitions-tp25693.html

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/