What is the granularity of parallelism in flink? For eg: if I am reading
from Kafka -> map -> Sink and I say parallel 2 does it mean it creates 2
consumer threads and allocates it on 2 separate task managers?

Also, it would be good to understand the difference between parallelism and
partitioning that also could be distributed across task managers.

Reply via email to