proto.lib

So Sánh Delivery Guarantees: At-Most-Once, At-Least-Once, Exactly-Once

Ba mức đảm bảo giao message phổ biến khác nhau về khả năng mất hoặc lặp message; exactly-once cần producer idempotent và cơ chế sequence number.

MessagingTrung bình2026-07-07
So Sánh Delivery Guarantees: At-Most-Once, At-Least-Once, Exactly-Once

Tags

#delivery-guarantees#at-most-once#at-least-once#exactly-once#idempotent-producer

Tài liệu tham khảo

Mở rộng

Animation gốc là một file HTML tự chứa, có thể nhúng lại ở bất kỳ trang nào khác. Mở file gốc

Liên quan

MessagingNâng cao

Kafka Exactly-Once Semantics

Producer idempotent với PID+sequence, transaction dùng transactional.id, consumer đọc read-committed để đảm bảo exactly-once.

#kafka#exactly-once#idempotent-producer#transactions
MessagingNâng cao

Sink stream (Kafka) xuống Lakehouse: file cột + commit metadata

Sink connector đọc liên tục từ Kafka, gom bản ghi theo cửa sổ thời gian thành file cột (Parquet), rồi commit một snapshot metadata mới cho bảng lakehouse; exactly-once đạt được bằng cách gắn việc commit offset Kafka với chính việc commit snapshot đó, không tách rời.

#kafka#sink-connector#lakehouse#table-format
MessagingTrung bình

Sink Connector ghi idempotent bằng upsert

Một sink kết nối stream vào database phải tránh trùng lặp khi redelivery: nó tính khoá xác định cho mỗi record và ghi bằng upsert (hoặc insert kèm unique constraint), đồng thời lưu version/offset của record để một retry cũ hơn không thể ghi đè bản mới hơn.

#sink-connector#idempotency#upsert#at-least-once