卡夫卡领袖选举什么时候发生?

Question

Kafka 高级制作人何时以及多久选举一次领导者？ 它是在发送每条消息之前还是在创建连接时只发送一次？

Answer 1

每个经纪人都有关于主题(和分区)列表及其领导者的信息，每当选出新领导者或分区数量发生变化时，动物园管理员都会更新这些信息。

因此，当生产者调用其中一个代理时，它会使用此信息列表进行响应。一旦生产者收到此信息，它就会缓存此信息并使用它来连接到领导者。因此，下次当它想要将消息发送到该特定主题(和分区)时，它将使用此缓存的信息。

让我们假设只有一个领导者，并且该主题/分区二重奏没有副本，它被粉碎了。在这种情况下，它将尝试连接到该领导者，但失败。它将尝试从它缓存的其他代理列表中获取领导者，以检查是否有此主题的领导者！由于它找不到任何，它将尝试击中同一个领导者(已死)，并且在达到最大重试次数后，它将引发异常！