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

Reply via email to