proto.lib

Redis Streams: Consumer Group và PEL

Minh họa cách Redis Streams cho phép nhiều consumer trong một group cùng đọc dữ liệu, theo dõi message chưa xử lý qua Pending Entries List và đảm bảo at-least-once delivery.

MessagingTrung bình2026-07-02
Redis Streams: Consumer Group và PEL

Tags

#redis#streams#consumer-group#at-least-once

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

MessagingTrung bình

Kafka Consumer Offset Commit: Auto vs Manual

So sánh auto-commit và manual-commit offset trong Kafka; manual commit sau khi xử lý xong giúp đảm bảo at-least-once, tránh mất dữ liệu khi crash.

#kafka#offset-commit#auto-commit#at-least-once
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

max.poll.interval.ms: vòng lặp rebalance vô tận

Coordinator kỳ vọng consumer gọi poll() trong vòng max.poll.interval.ms; nếu một batch xử lý quá lâu và bỏ lỡ mốc này, consumer bị coi là chết, partition bị revoke, commit bị từ chối, việc được giao lại — và consumer mới nhận cũng xử lý chậm y hệt, tạo vòng lặp rebalance không tiến triển.

#kafka#max-poll-interval-ms#consumer-group#rebalance