Skip to main content

start_binlog_stream

laminar_connectors::cdc::mysql::mysql_io

Function start_binlog_stream 

Source 
pub async fn start_binlog_stream(
    conn: Conn,
    config: &MySqlCdcConfig,
    gtid_set: Option<&GtidSet>,
    position: Option<&BinlogPosition>,
) -> Result<BinlogStream, ConnectorError>
Expand description

Starts a binlog replication stream from the MySQL server.

The connection is consumed by the binlog stream (MySQL protocol requirement).

§Arguments

  • conn - MySQL connection (consumed)
  • config - CDC configuration
  • gtid_set - Optional GTID set for GTID-based replication
  • position - Optional binlog position for file/position-based replication

§Errors

Returns ConnectorError::ConnectionFailed if the binlog stream cannot be started.