proto.lib

Pulsar Functions - Serverless Stream Processing

Hàm xử lý nhẹ được Pulsar tự động chạy khi có message mới trên topic đầu vào và ghi kết quả ra topic đầu ra, không cần cụm xử lý riêng.

MessagingTrung bình2026-07-17
Pulsar Functions - Serverless Stream Processing

Tags

#pulsar#pulsar-functions#serverless#stream-processing#event-driven

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

Pulsar Subscription Types: bốn cách đọc cùng một topic

Pulsar tách cursor (vị trí đọc) khỏi topic và gắn vào subscription: exclusive (một consumer, thứ tự chặt), failover (một active + standby), shared (round-robin, mất thứ tự) và key-shared (song song giữa consumer nhưng vẫn giữ thứ tự theo key); vì cursor thuộc subscription, nhiều subscription có thể đọc độc lập cùng một topic với chế độ khác nhau.

#pulsar#subscription#exclusive#failover