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
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