How does flink read data from kafka number of TM's are more than topic partitions

[Taher Koitawala]

Hi All,
         Let's say a topic in kafka has 5 partitions. If I spawn 10 Task
Managers with 1 slot each and parallelism is 10 then how will records be
read from the kafka topic if I use the FlinkKafkaConsumer to read.

Will 5 TM's read and the rest be ideal in that case? Is over subscribing
the number of TM's than the number of partitions in the Kafka topic
guarantee high throughput?

Regards,
Taher Koitawala
GS Lab Pune
+91 8407979163