Struct MySqlCdcConfig 

pub struct MySqlCdcConfig {

    pub host: String,
    pub port: u16,
    pub database: Option<String>,
    pub username: String,
    pub password: Option<String>,
    pub ssl_mode: SslMode,
    pub server_id: u32,
    pub gtid_set: Option<GtidSet>,
    pub binlog_filename: Option<String>,
    pub binlog_position: Option<u64>,
    pub use_gtid: bool,
    pub snapshot_mode: SnapshotMode,
    pub poll_timeout: Duration,
    pub max_poll_records: usize,
    pub heartbeat_interval: Duration,
    pub connect_timeout: Duration,
    pub read_timeout: Duration,
    pub table_include: Vec<String>,
    pub table_exclude: Vec<String>,
    pub database_filter: Option<String>,
}

Configuration for the MySQL CDC source connector.

Fields

host: String

MySQL host address.

port: u16

MySQL port.

database: Option<String>

Database name (optional for binlog replication).

username: String

Username for authentication.

password: Option<String>

Password for authentication.

ssl_mode: SslMode

SSL mode for the connection.

server_id: u32

Server ID for the replica (must be unique in the topology). MySQL requires each replica to have a unique server ID.

gtid_set: Option<GtidSet>

GTID set to start replication from (None = use binlog position). Using GTID is recommended for failover support.

binlog_filename: Option<String>

Binlog filename to start from (if not using GTID).

binlog_position: Option<u64>

Binlog position to start from (if not using GTID).

use_gtid: bool

Whether to use GTID-based replication (recommended).

snapshot_mode: SnapshotMode

How to handle the initial data snapshot.

poll_timeout: Duration

Timeout for each poll operation.

max_poll_records: usize

Maximum records to return per poll.

heartbeat_interval: Duration

Heartbeat interval for the binlog connection.

connect_timeout: Duration

Connection timeout.

read_timeout: Duration

Read timeout for binlog events.

table_include: Vec<String>

Tables to include (format: “database.table” or just “table”). Empty = all tables.

table_exclude: Vec<String>

Tables to exclude from replication.

database_filter: Option<String>

Database filter (if set, only replicate from this database).

Implementations

impl MySqlCdcConfig

pub fn new(host: &str, username: &str) -> Self

Creates a new config with required fields.

pub fn with_server_id(host: &str, username: &str, server_id: u32) -> Self

Creates a new config with server ID.

pub fn connection_url(&self) -> String

Builds a MySQL connection URL.

pub fn from_config(config: &ConnectorConfig) -> Result<Self, ConnectorError>

Parses configuration from a generic ConnectorConfig.

Errors

Returns ConnectorError if required keys are missing or values are invalid.

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

Validates the configuration.

Errors

Returns ConnectorError::ConfigurationError for invalid settings.

pub fn should_include_table(&self, database: &str, table: &str) -> bool

Returns whether a table should be included based on include/exclude lists.

pub fn replication_mode(&self) -> &'static str

Returns the replication mode description.

Trait Implementations

impl Clone for MySqlCdcConfig

fn clone(&self) -> MySqlCdcConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MySqlCdcConfig

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for MySqlCdcConfig

fn default() -> Self

Returns the “default value” for a type.