proto.lib

Cron Cluster: Lock để chỉ Fire Một Lần

Một job kiểu cron chạy trên N instance giống hệt nhau sẽ fire N lần nếu không kiểm soát; mỗi instance đua giành một lock khoá theo tên-job cộng khe-giờ đã lên lịch, bên thua bỏ qua thay vì tự enqueue lại, còn bên thắng chỉ nên enqueue task chứ không làm việc thật ngay dưới lock.

MessagingNâng cao2026-08-20
Cron Cluster: Lock để chỉ Fire Một Lần

Tags

#scheduled-job#distributed-lock#leader-election#cron#idempotency#clock-skew

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

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
MessagingTrung bình

Lệch leader và Preferred Leader Election trong Kafka

Sau các lần fail-over và restart, leadership của partition trôi dạt khiến một vài broker giữ phần lớn leader (và do đó phần lớn traffic produce/fetch) dù replica vẫn được rải đều; Preferred Leader Election đưa leadership trở lại broker đầu tiên trong replica list (preferred leader) để cân bằng lại.

#kafka#leader-election#partition-leadership#rebalance