On Thu, Nov 22, 2018 at 10:10 AM Raghu Angadi <[email protected]> wrote:
> - New partitions will be ignored during runtime. > - Update will not succeed either. Error message on the workers should > explain the mismatch. > This is the current state. Supporting changes to number of partition is quite doable if there is enough user interested (even in the current UnnoundedSource API framework). > > On Thu, Nov 22, 2018 at 2:15 AM Jozef Vilcek <[email protected]> > 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 >> >
