Đang tải nội dung…
Đang tải nội dung…
3 bài viết phù hợp với “Stream Processing”
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.
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.