Đang tải nội dung…
Đang tải nội dung…
Kiến trúc sự kiện, cơ chế Partition Log và đảm bảo độ tin cậy giữa Producer - Consumer.
01Tumbling window cần một chính sách grace rõ ràng. Lab đưa năm record qua Kafka để đo record nào được cập nhật và record nào đã quá muộn.
Thứ tự nhận message không luôn là thứ tự nghiệp vụ. Ben và Tom so sánh arrival order, event time và domain version trên cùng một luồng Kafka.
Snapshot và WAL stream phải gặp nhau tại một log position nhất quán. Lab cho thấy tạo ranh giới quá muộn làm projection giữ giá cũ.
Ben tưởng commit offset sau khi xử lý là đủ. Một lần crash cho thấy vì sao consumer phải chịu replay và business effect cần idempotency ngay tại nơi ghi.
10.000 record thật cho thấy tăng partition không tách một key nóng; salting hạ đỉnh nhưng đổi phạm vi bảo toàn thứ tự.