我了解了Kafka复制协议。我发现Kafka保持LEO和HW。据我了解,
LEO:副本看到的最新消息的偏移量。
HW:最新消息的偏移量,可以保证每个副本已经看到。
可以将Kafka生产者设置为这些确认方法。
所以我的问题是,领导者如何根据卡夫卡生产者使用的确认方法来提高硬件水平。
我的理解是,
对于acks = 0,Leader会在看到新消息时推进硬件。
for acks = 1,Leader将新消息写入本地日志时,Leader会提高硬件的性能。
for acks = all,当每个跟随者发送确认消息时,领导者都会提高硬件。
这是正确的吗?任何人都可以澄清吗?
[通过进一步的探索,我发现在硬件配置中设置的硬件升级与确认方法之间没有关系。不管设置为acks,领导副本都将在前进硬件之前等待所有其他关注者保留该消息。