Hi, Following need more elaboration after reading kafka docs:
1- In a scenario during leader fails over, what happens to messages that are not committed to other followers and to the messages that producer keep in sending (in async mode) till new leader is elected. Can the producer buffer these messages till the failover gets completed (Do we see exceptions. Are these all lost? 2. Broker load distribution or to be exact partition load distribution is done via hashed key mod no of partition, is that correct? How is it done at the consumer side where one thread per partition (for high-level consumer) How is the faliover handlled 3. How do we configure producer for wait for leader ack and wait for commited act which Jun Rao talks about in his 2013 apachecon presentation -- Kind Regards, Shafaq
