Hi Sohi!
On Wed, Jan 23, 2019 at 9:01 PM sohimankotia wrote:
> 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)
>
There isn't
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
