For a keyed stream (where the key is also the message key in the source kafka topic), is the parallelism of the job restricted to the number of partitions in the topic?
Source topic has 5 partitions, but available task slots are 12. (3 task managers each with 4 slots) Moiz
