我读过https://cwiki.apache.org/confluence/display/kafka/kafka+replication
因此，对于每个提交的消息，我们保证消息存储在>内存中的多个副本中。但是，不能保证任何>复制副本都已将提交消息持久化到磁盘
在ack之后只将消息存储在跟随者的内存中以实现低延迟是有意义的。但这篇文章没有说明这位领导人是否坚持这一信息。如果领导崩溃了怎么办？
我读过https://cwiki.apache.org/confluence/display/kafka/kafka+replication
因此，对于每个提交的消息，我们保证消息存储在>内存中的多个副本中。但是，不能保证任何>复制副本都已将提交消息持久化到磁盘
在ack之后只将消息存储在跟随者的内存中以实现低延迟是有意义的。但这篇文章没有说明这位领导人是否坚持这一信息。如果领导崩溃了怎么办？
1条答案
按热度按时间xxls0lw81#
在思考了这个主题之后，我发现领导也不需要坚持这个信息。提交的消息保证是通过假设isr中至少有一个副本将继续存在而提供的。如果原领导崩溃，将使用提交的消息选举新领导