Hey Jae, > what happens when we re-elect leaderships for each partitions? Is this >handled automatically?
Yes. Samza will get an exception, which will trigger it to refresh its metadata. This refresh should cause Samza to see the new leader. You shouldn't need to restart when a leader election occurs. Cheers, Chris On 1/14/15 5:07 PM, "Bae, Jae Hyeon" <[email protected]> wrote: >Hi Samza Devs > >As Samza Kafka consumer does not depend on Zookeeper coordination, I need >to restart the job when we add more partitions. Then, what happens when we >re-elect leaderships for each partitions? Is this handled automatically? >Or, do we need to restart the job also in this case? I believe this will >be >handled automatically by some exception handling on Kafka consumer. > >Thank you >Best, Jae
