Hey Yong, Samza does not support dynamic scaling. You'd have to bump up your yarn.container.count (assuming you're using YARN) and re-start the job.
Cheers, Chris On 10/13/13 10:42 AM, "Yong Yuan" <[email protected]> wrote: >Hi, folks, > >Does Samza support scaling up processing at runtime? That is, if I add new >Kafka brokers or increase the number of partitions for a topic while my >Samza job is running, will Samza allocate more stream tasks accordingly? >Or >do I have to relaunch the tasks? > >Thanks,
