Kafka 支持以下三種消息傳遞語義：
1. At most once (至多一次)：在這種語義中，消息可能會丟失，但絕不會被重復(fù)處理。生產(chǎn)者發(fā)送消息后，不會進行任何確認或重試，因此可能會出現(xiàn)消息丟失的情況。
2. At least once (至少一次)：在這種語義中，消息絕不會丟失，但可能會被處理多次。生產(chǎn)者發(fā)送消息后，消費者可以通過應(yīng)答機制來確保消息已正確處理，但如果網(wǎng)絡(luò)故障、消費者故障等情況導(dǎo)致生產(chǎn)者認為消息未被處理，則會重新發(fā)送消息。
3. Exactly once (僅一次)：這是最嚴格的消息傳遞語義，確保每條消息只會被處理一次。Kafka 通過事務(wù)和冪等性機制實現(xiàn)了精確一次語義，以確保消息在生產(chǎn)者與消費者之間的傳遞過程中不會丟失也不會被重復(fù)處理。
由于 Exactly once 語義較為復(fù)雜且性能開銷較大，因此 At least once 通常是最常用的消息傳遞語義。在 Kafka 中，消費者可以根據(jù)自身需求選擇適合的消息傳遞語義來保證消息的可靠性和一致性。
億速云公眾號
手機網(wǎng)站二維碼
