Expand description
Per-flow replication worker. It drives one directional connect pipeline from
SourceConsumer to TargetSink, plus the heartbeat and checkpoint
background tasks, with build-retry resilience and clean shutdown.
Structsยง
- Flow
Worker - One directional replication flow: the running connect runtime plus the heartbeat and checkpoint background tasks.
- Flow
Worker Params - Parameters to start a
FlowWorker. The supervisor resolves selectors into a concrete topic list and passes the per-flow cluster addresses, aliases, naming policy, residency policies, and security here.