proto.lib

Competing Consumers Work Queue

Nhiều worker cùng lấy message từ một queue, mỗi message chỉ được xử lý bởi đúng một worker để chia tải công việc.

MessagingCơ bản2026-07-02
Competing Consumers Work Queue

Tags

#work-queue#load-balancing#worker-pool

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

Xử lý song song theo Key (Key-Level Parallel Consumption)

Thay vì một thread một partition, consumer định tuyến record theo key vào các hàng đợi riêng: mọi record cùng key được xử lý tuần tự để giữ thứ tự, còn các key khác nhau chạy song song — tách rời throughput khỏi số partition.

#parallel-consumption#key-based-routing#ordering#offset-commit
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
MessagingCơ bản

Queue-Based Load Leveling

Hàng đợi đóng vai trò bộ đệm giữa client gửi burst request và worker xử lý theo tốc độ ổn định, bảo vệ backend khỏi quá tải.

#queue#load-leveling#backpressure#buffering