Kafka Leader 选举什么时候发生?
When does Kafka Leader Election happen?
Kafka High Level Producer 何时以及多久选举一次领导者?
它是在发送每条消息之前执行还是仅在创建连接时执行一次?
Every broker has a information about the list of topics(and partitions) and their leaders which will be kept up to date by the zoo keeper whenever the new leader is elected or when the number of partition changes.
因此,当生产者调用其中一个代理时,它会使用此信息列表进行响应。一旦生产者收到此信息,它就会将其缓存起来并使用它来连接到领导者。因此,下次当它想将消息发送到该特定主题(和分区)时,它将使用此缓存信息。
让我们假设只有一个领导者并且没有那个主题/分区二重奏的副本并且它被压垮了。在这种情况下,它将尝试连接到该领导者,但失败了。它会尝试从它缓存的其他代理列表中获取领导者,以检查是否有该主题的领导者!因为它没有找到任何东西,它会尝试攻击同一个领导者(已经死了)并且在达到最大重试次数后它会抛出异常!
Kafka High Level Producer 何时以及多久选举一次领导者? 它是在发送每条消息之前执行还是仅在创建连接时执行一次?
Every broker has a information about the list of topics(and partitions) and their leaders which will be kept up to date by the zoo keeper whenever the new leader is elected or when the number of partition changes.
因此,当生产者调用其中一个代理时,它会使用此信息列表进行响应。一旦生产者收到此信息,它就会将其缓存起来并使用它来连接到领导者。因此,下次当它想将消息发送到该特定主题(和分区)时,它将使用此缓存信息。
让我们假设只有一个领导者并且没有那个主题/分区二重奏的副本并且它被压垮了。在这种情况下,它将尝试连接到该领导者,但失败了。它会尝试从它缓存的其他代理列表中获取领导者,以检查是否有该主题的领导者!因为它没有找到任何东西,它会尝试攻击同一个领导者(已经死了)并且在达到最大重试次数后它会抛出异常!