proto.lib

Dual-Run: nâng cấp version của stream processor

Nâng cấp logic của một stream processor bằng cách chạy version mới SONG SONG với version cũ trên cùng input, ghi ra output topic/table riêng, cho tới khi một job so sánh xác nhận khác biệt chỉ nằm ở phần chủ đích thay đổi — rồi mới chuyển consumer sang và loại bỏ version cũ.

MessagingNâng cao2026-08-25
Dual-Run: nâng cấp version của stream processor

Tags

#dual-run#stream-processing#migration#versioning#diffing#state-rebuild

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

MessagingTrung bình

Session Window theo khoảng ngừng hoạt động (Session Window Gaps)

Session window không cắt theo mốc thời gian cố định mà gom các sự kiện của một khoá khi chúng còn liên tiếp đến, và đóng lại sau một khoảng ngừng (gap) không có sự kiện mới; một sự kiện trễ có thể buộc engine gộp lại hai session tưởng đã tách rời.

#session-window#stream-processing#windowing#gap-timeout
MessagingNâng cao

Retraction Stream và Upsert Stream cho Aggregate có thể giảm

Một aggregate streaming có thể giảm giá trị (ví dụ đếm bản ghi đang active) không thể publish như append-only; nó phải phát cặp RETRACT rồi INSERT (retraction stream) hoặc phát một bản ghi upsert theo khoá với ngữ nghĩa latest-wins.

#retraction-stream#upsert#changelog#stream-processing
MessagingTrung bình

Đưa CDC vào Search Index (đồng bộ tài liệu)

Change event từ database được biến đổi thành document cho search index, nhưng một document thường ghép dữ liệu từ nhiều bảng nên pipeline phải denormalize ngay tại nguồn hoặc tra cứu phần còn thiếu; delete và các thay đổi tới không đúng thứ tự phải mang version để bản cũ không ghi đè bản mới.

#cdc#search-index#denormalization#reindex