Struct WorkerConfig 

pub struct WorkerConfig {

    pub connector_id: String,
    pub kafka_bootstrap: String,
    pub schema_registry_url: String,
    pub replication_factor: ReplicationFactor,
    pub postgres_url: SecretString,
    pub postgres_slot: String,
    pub postgres_publication: String,
    pub postgres_schema: String,
    pub postgres_tables: Vec<String>,
    pub topic_prefix: String,
    pub batch_size: usize,
    pub commit_interval_ms: u64,
    pub poll_backoff_ms: u64,
    pub health_listen: SocketAddr,
    pub client_dispatch_queue_capacity: usize,
    pub client_frame_max_bytes: u64,
    pub broker_protocol: BrokerProtocol,
    pub broker_ca_path: Option<PathBuf>,
    pub broker_server_name: Option<String>,
    pub broker_cert_path: Option<PathBuf>,
    pub broker_key_path: Option<PathBuf>,
    pub broker_sasl_username: Option<String>,
    pub broker_sasl_password: Option<SecretString>,
    pub broker_sasl_mechanism: Option<BrokerSaslMechanism>,
}

Complete configuration for one managed Postgres source connector.

Fields

connector_id: String

Stable connector ID and checkpoint key.

kafka_bootstrap: String

Kafka bootstrap address.

schema_registry_url: String

Confluent-compatible Schema Registry base URL.

replication_factor: ReplicationFactor

Replicas used when the worker creates data and checkpoint topics.

postgres_url: SecretString

PostgreSQL connection URL. Formatting is always redacted.

postgres_slot: String

PostgreSQL logical replication slot.

postgres_publication: String

PostgreSQL publication.

postgres_schema: String

PostgreSQL schema containing the selected tables.

postgres_tables: Vec<String>

Comma-delimited table names captured from the publication.

topic_prefix: String

Prefix prepended to source topics with a dot separator; empty disables it.

batch_size: usize

Maximum records buffered before a Kafka durability barrier.

commit_interval_ms: u64

Maximum time between Kafka durability barriers, in milliseconds.

poll_backoff_ms: u64

Delay after PostgreSQL reports no new changes, in milliseconds.

health_listen: SocketAddr

Address serving /live, /ready, and /metrics.

client_dispatch_queue_capacity: usize

Capacity of each Kafka client’s pending request dispatch queue.

client_frame_max_bytes: u64

Maximum accepted Kafka response frame size in bytes.

broker_protocol: BrokerProtocol

Broker security protocol.

broker_ca_path: Option<PathBuf>

PEM file containing broker CA certificates.

broker_server_name: Option<String>

TLS SNI name used to verify the broker certificate.

broker_cert_path: Option<PathBuf>

PEM client certificate chain for mTLS.

broker_key_path: Option<PathBuf>

PEM private key for mTLS.

broker_sasl_username: Option<String>

SASL username.

broker_sasl_password: Option<SecretString>

SASL password. Formatting is always redacted.

broker_sasl_mechanism: Option<BrokerSaslMechanism>

SASL PLAIN or SCRAM mechanism.

Implementations

impl WorkerConfig

pub fn validate(&self) -> Result<(), String>

Validate cross-field resource and security constraints.

Errors

Returns an error for an oversized batch, invalid client limit, incomplete mTLS identity, or security material inconsistent with the protocol.

pub fn postgres_source(&self) -> PostgresSourceConfig

Build the existing typed PostgreSQL source configuration.

Panics

Panics only if called before Self::validate with a batch size that does not fit u32.

pub const fn commit_interval(&self) -> Duration

Commit interval as a standard duration.

pub const fn poll_backoff(&self) -> Duration

Empty-poll backoff as a standard duration.

pub fn checkpoint_key(&self) -> String

Stable checkpoint key scoped to the connector and PostgreSQL source.

pub fn client_security(&self) -> Result<Option<ClientSecurity>, String>

Validated Kafka client security, or None for plaintext.

Errors

Returns an error when the security fields are incomplete or inconsistent.

Trait Implementations

impl Args for WorkerConfig

fn group_id() -> Option<Id>

Report the [ArgGroup::id][crate::ArgGroup::id] for this set of arguments

fn augment_args<'b>(__clap_app: Command) -> Command

Append to [Command] so it can instantiate Self via [FromArgMatches::from_arg_matches_mut]

fn augment_args_for_update<'b>(__clap_app: Command) -> Command

Append to [Command] so it can instantiate self via [FromArgMatches::update_from_arg_matches_mut]

impl Clone for WorkerConfig

fn clone(&self) -> WorkerConfig

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl CommandFactory for WorkerConfig

fn command<'b>() -> Command

Build a [Command] that can instantiate Self.

fn command_for_update<'b>() -> Command

Build a [Command] that can update self.

impl FromArgMatches for WorkerConfig

fn from_arg_matches(__clap_arg_matches: &ArgMatches) -> Result<Self, Error>

Instantiate Self from [ArgMatches], parsing the arguments as needed.

fn from_arg_matches_mut( __clap_arg_matches: &mut ArgMatches, ) -> Result<Self, Error>

Instantiate Self from [ArgMatches], parsing the arguments as needed.

fn update_from_arg_matches( &mut self, __clap_arg_matches: &ArgMatches, ) -> Result<(), Error>

Assign values from ArgMatches to self.

fn update_from_arg_matches_mut( &mut self, __clap_arg_matches: &mut ArgMatches, ) -> Result<(), Error>

Assign values from ArgMatches to self.

impl Parser for WorkerConfig

fn parse() -> Self

Parse from std::env::args_os(), [exit][Error::exit] on error.

fn try_parse() -> Result<Self, Error>

Parse from std::env::args_os(), return Err on error.

fn parse_from<I, T>(itr: I) -> Self

where I: IntoIterator<Item = T>, T: Into<OsString> + Clone,

Parse from iterator, [exit][Error::exit] on error.

fn try_parse_from<I, T>(itr: I) -> Result<Self, Error>

where I: IntoIterator<Item = T>, T: Into<OsString> + Clone,

Parse from iterator, return Err on error.

fn update_from<I, T>(&mut self, itr: I)

where I: IntoIterator<Item = T>, T: Into<OsString> + Clone,

Update from iterator, [exit][Error::exit] on error.

fn try_update_from<I, T>(&mut self, itr: I) -> Result<(), Error>

where I: IntoIterator<Item = T>, T: Into<OsString> + Clone,

Update from iterator, return Err on error.