Skip to main content

Module sink

Module sink 

Source
Expand description

Sink side: residency gate, naming, and provenance loop-guard, then produce to the target and emit source-to-target offset syncs.

Structsยง

SinkParams
Parameters required to start a TargetSink.
TargetSink
A [Sink] that applies residency filtering, topic renaming, and loop-guard logic before it produces records to the target cluster.