天天看點

kafka生産者寫入消息流程

kafka生産者寫入消息流程

producer 寫入消息流程如下:

1)producer 先從 zookeeper 的 "/brokers/…/state"節點找到該 partition 的 leader

2)producer 将消息發送給該 leader

3)leader 将消息寫入本地 log

4)followers 從 leader pull 消息,寫入本地 log 後向 leader 發送 ACK

5)leader 收到所有 ISR 中的 replication 的 ACK 後,增加 HW(high watermark,最後 commit

的 offset)并向 producer 發送 ACK