- New partitions will be ignored during runtime. - Update will not succeed either. Error message on the workers should explain the mismatch.
On Thu, Nov 22, 2018 at 2:15 AM Jozef Vilcek <jozo.vil...@gmail.com> wrote: > 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 >
