Hello,
just wanted to check how does Beam KafkaIO behaves when partitions are
added to the topic.
Will they be picked up or ignored during the runtime?
Will they be picked up on restart with state restore?

Thanks,
Jozef

Reply via email to