Đang tải nội dung…
Đang tải nội dung…
6 bài viết phù hợp với “Kafka Streams”
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.
Đi qua lỗi dual-write, relay gửi lại và inbox chống trùng bằng PostgreSQL cùng Redis Streams thật. Phân biệt điều lab chứng minh với durability và exactly-once ngoài phạm vi.
Từ một hiện tượng bất thường trong production đến cơ chế bên trong hệ thống. Đây là cách WhyBit tiếp cận kiến thức Backend Engineering.