1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
//! MySQL/MariaDB CDC implementation using binary log replication
//!
//! Supports:
//! - MySQL 5.7+, 8.0+
//! - MariaDB 10.2+
//! - Row-based replication (binlog_format=ROW)
//! - GTID-based replication
//! - Table filtering
//! - Schema inference
//!
//! # Architecture
//!
//! ```text
//! MySQL Binlog → MySqlBinlogClient → BinlogDecoder → CdcEvent
//! ```
//!
//! # Example
//!
//! ```rust,no_run
//! use rivven_cdc::mysql::{MySqlCdc, MySqlCdcConfig};
//!
//! # async fn example() -> anyhow::Result<()> {
//! let config = MySqlCdcConfig::new("localhost", "root")
//! .with_password("password")
//! .with_database("mydb")
//! .with_server_id(1001);
//!
//! let cdc = MySqlCdc::new(config);
//! # Ok(())
//! # }
//! ```
pub use *;
pub use *;
pub use *;
pub use *;