proto.lib

SQS Visibility Timeout & Redelivery

Visibility timeout kiểm soát khoảng thời gian message ẩn khỏi các consumer khác sau khi được nhận; nếu consumer không xoá kịp, message sẽ được giao lại.

MessagingCơ bản2026-07-07
SQS Visibility Timeout & Redelivery

Tags

#sqs#visibility-timeout#at-least-once#in-flight#redelivery

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 Share Groups: hành vi hàng đợi trên log

Thay vì gán mỗi consumer một partition cố định, share group cho phép NHIỀU consumer cùng đọc một partition, ack từng record riêng lẻ — mang lại hành vi work-queue (nhiều consumer hơn partition, ack/redeliver theo record) trên cùng broker vẫn giữ log replay được, đổi lại mất thứ tự per-record.

#kafka#share-group#kip-932#queue-semantics
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
MessagingTrung bình

Drain Consumer trước khi Deploy

Khi deploy, instance consumer phải dừng fetch message mới, xử lý xong phần đang giữ, commit rồi mới exit; grace period của orchestrator phải dài hơn thời gian xử lý message lâu nhất, nếu không platform sẽ kill giữa chừng và broker redeliver phần việc đó.

#graceful-shutdown#drain#deploy#sigterm