proto.lib

NATS: Core Pub/Sub và JetStream

Minh họa NATS core pub/sub theo subject dạng fire-and-forget, sau đó mở rộng bằng JetStream để có persistence, replay và acknowledgment.

MessagingTrung bình2026-07-02
NATS: Core Pub/Sub và JetStream

Tags

#nats#jetstream#pubsub#streaming

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

MessagingCơ bản

NATS JetStream KV & Object Store

JetStream cung cấp key-value store và object store dựng trên stream, hỗ trợ watch thay đổi và kiểm soát tương tranh theo revision.

#nats#jetstream#key-value#object-store
MessagingTrung bình

NATS JetStream Stream Mirror

JetStream cho phép tạo một stream mirror để sao chép toàn bộ message từ stream nguồn sang stream khác, kể cả giữa các cluster hoặc domain khác nhau.

#nats#jetstream#stream-mirror#replication
MessagingNâng cao

CDC Snapshot Watermark Consistency (khởi động CDC nhất quán)

Khi bắt đầu bắt sự kiện thay đổi trên một bảng đang sống, connector cần cả toàn bộ dữ liệu hiện tại lẫn mọi thay đổi từ thời điểm đó, không thiếu không lặp. Kỹ thuật snapshot watermark bọc mỗi chunk snapshot giữa hai sự kiện WATERMARK (low/high) ghi vào stream, và khi resolve, thay đổi nào rơi trong cửa sổ đó luôn thắng bản snapshot của cùng dòng.

#cdc#snapshot#watermark#consistency