| 定位 | MySQL binlog 增量订阅与解析组件 |
|---|---|
| 原理 | 模拟从库发送 dump 协议，接收 binlog 并解析 |
| 输出 | Entry / RowChange（行级增删改） |
| 投递 | TCP 客户端拉取，或直接投递 Kafka/RocketMQ 等 |
数据流向
数据流向
MySQL Master
→（dump 协议推送 binlog）
Canal Server 解析为 Entry/RowChange
→ Kafka 或 canal client 消费Canal 依赖 ROW 格式 binlog，并需要独立 slaveId（不与真实从库冲突）。