Skip to main content

Module sink

Module sink 

Source
Expand description

NATS sink. Core publishes are fire-and-forget; JetStream collects PublishAckFutures and drains them in flush. Optional server-side Nats-Msg-Id dedup suppresses replay duplicates within the broker window, but is not a coordinated checkpoint commit protocol.

Structs§

NatsSink
NATS sink — core and JetStream modes.