CANAL

CANAL 是一个开源的 MySQL 数据库增量日志解析与同步中间件，由阿里巴巴集团研发并开源。它通过模拟 MySQL Slave 的方式，实时订阅并解析主库的 binlog 日志，将数据变更（INSERT/UPDATE/DELETE）以结构化事件的形式投递至下游系统（如 Kafka、RocketMQ、Elasticsearch 或自定义客户端），广泛应用于数据异构、缓存更新、业务解耦和实时数仓等场景。

软件优势

1. 高兼容性：支持 MySQL 5.6/5.7/8.0 及阿里云 PolarDB-X 等主流数据库协议；
2. 低侵入性：无需修改业务代码或数据库表结构，仅需开启 binlog 并授权 Canal 账号；
3. 高可靠性：提供基于 ZooKeeper 或 Nacos 的集群高可用与位点自动恢复机制；
4. 易扩展性：支持多级订阅、灵活过滤（按库、表、字段）、自定义序列化格式（JSON/Protobuf）；
5. 生态丰富：原生集成 Spring Boot Starter、Prometheus 监控、Web 管理控制台（Canal Admin）。

使用教程

1. 环境准备：确保 MySQL 已开启 binlog（格式为 ROW），并创建具备 REPLICATION SLAVE 权限的账号；
2. 下载部署：从 GitHub 官方仓库获取最新 release 包，解压后配置 conf/example/instance.properties 文件；
3. 启动服务：执行 bin/startup.sh（Linux/Mac）或 bin/startup.bat（Windows），检查 logs/canal/canal.log 是否启动成功；
4. 接入客户端：引入 canal-client 依赖，编写 Java 示例程序连接 Canal Server，订阅指定 destination 并处理 Message 事件；
5. （可选）配置管理：部署 Canal Admin 控制台，实现 instance 动态启停、配置可视化与集群状态监控。

更新日志

• v1.1.7（2023年发布）：增强对 MySQL 8.0.32+ 的兼容性，优化 DDL 解析稳定性，新增 Canal Adapter 对 PostgreSQL 的初步适配支持；
• v1.1.6：修复 Canal Admin 在高并发场景下的配置同步延迟问题，提升 Kafka 消息投递的幂等性保障；
• v1.1.5：引入轻量级嵌入式模式（Embedded Server），支持无中心化部署；完善 Docker 官方镜像与 Helm Chart 支持；
• 更早版本持续优化性能、日志诊断能力及安全加固（如 TLS 加密通信、Token 认证等）。详细变更请参考 GitHub 官方 Release 页面。