brokerA是leader,brokerB是follower,当brokerA重启,brokerB成为leader,brokerA还会保存之前已经消费的消息么
时间: 2024-04-05 17:36:05 浏览: 43
Leader_Follower.zip_Leader-Follower_avoidance obstacle_formation
当brokerA重启后,如果brokerB成为新的leader,那么brokerA会保留之前已经消费的消息。这是因为Kafka采用的是基于日志的消息存储模型,每个broker上的消息都会被保存在磁盘上,即使broker失效或者重启,之前的消息也不会丢失。
当brokerB成为新的leader时,它会继续从brokerA同步未消费的消息,并将这些消息同步到自己的副本中。同时,已经被消费的消息也会被保留在brokerA的日志中,以便之后需要时进行查找和恢复。
需要注意的是,当brokerA重启后,它可能需要一些时间来从磁盘中重新加载之前的日志数据,因此在此期间可能会出现一些延迟。但是,一旦brokerA加载完成,之前已经消费的消息仍然可以从brokerA的日志中读取。
阅读全文