Struct FlowWorkerParams 

pub struct FlowWorkerParams {
    pub flow_name: String,
    pub source_bootstrap: String,
    pub target_bootstrap: String,
    pub source_alias: String,
    pub target_alias: String,
    pub naming: NamingPolicy,
    pub topics: Vec<String>,
    pub target_zones: Vec<String>,
    pub policies: Vec<PolicyConfig>,
    pub group_selector: Selector,
    pub security_source: Option<ClientSecurity>,
    pub security_target: Option<ClientSecurity>,
}

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.

Fields

flow_name: String

Unique flow name (e.g. "us-east__eu-west"); seeds the consumer group id and the checkpoint-store key.

source_bootstrap: String

Bootstrap address of the source cluster.

target_bootstrap: String

Bootstrap address of the target cluster.

source_alias: String

Alias of the source cluster (stamped as provenance / used for MM2 names).

target_alias: String

Alias of the target cluster (written into heartbeat records).

naming: NamingPolicy

How source topics are renamed on the target.

topics: Vec<String>

Already-resolved source topic list (supervisor resolves selectors).

target_zones: Vec<String>

Compliance zones of the target cluster (used for residency checks).

policies: Vec<PolicyConfig>

Residency policies to enforce on the sink.

group_selector: Selector

Selector for which consumer groups the checkpoint task translates.

security_source: Option<ClientSecurity>

Optional TLS/SASL security for the source cluster.

security_target: Option<ClientSecurity>

Optional TLS/SASL security for the target cluster.