[Antonio Si]

Hello Beam community,

I am experimenting with the new SDF KafkaIO in a bit more detail. I have a
quick question. How are the topics and partitions got assigned to each Task
Manager?

Can someone point me to the code?

Thanks in advance.

Antonio.