Khi xây dựng hệ thống với kiến trúc Event-Driven, làm thế nào để đảm bảo tính thứ tự của các sự kiện (Event Ordering) khi hệ thống có nhiều Consumer xử lý song song?

Question

Accepted Answer

Trong các hệ thống phân tán, việc đảm bảo thứ tự sự kiện là một bài toán khó do tính chất bất đồng bộ của mạng và xử lý song song.
Giải pháp:

Partitioning (Sharding) theo Key: Trong Kafka, bạn có thể sử dụng cùng một Partition Key (ví dụ: UserID) cho các sự kiện liên quan đến cùng một thực thể. Tất cả sự kiện có cùng Key sẽ được gửi vào cùng một Partition, đảm bảo chúng được xử lý tuần tự bởi một Consumer duy nhất.
Sequence Number: Đính kèm một số thứ tự (Sequence Number) hoặc Timestamp vào payload của sự kiện. Consumer sẽ kiểm tra số thứ tự này để quyết định có xử lý ngay hay đưa vào hàng đợi tạm thời nếu sự kiện đến sai thứ tự.
Version Check: Sử dụng cơ chế Optimistic Locking với version của bản ghi để đảm bảo rằng các cập nhật cũ không ghi đè lên các cập nhật mới hơn.

Lưu ý:
Việc ép buộc thứ tự sẽ làm giảm khả năng mở rộng (Scalability) vì bạn không thể xử lý song song các sự kiện trên cùng một Partition Key.

Khi xây dựng hệ thống với kiến trúc Event-Driven, làm thế nào để đảm bảo tính thứ tự của các sự kiện (Event Ordering) khi hệ thống có nhiều Consumer xử lý song song?

Khóa học System Design & High Scalability

Tải Tuyển Tập 100+ Câu Hỏi Phỏng Vấn Chuyên Sâu (PDF)

Cần Mentor Phỏng Vấn Thử 1-1 & Tối Ưu CV?

Kiểm Tra CV Chuẩn ATS Miễn Phí

Câu hỏi system design liên quan cùng chủ đề