Maxwell's daemon

这是一个变更数据捕获（CDC）应用，能够读取 MySQL 的 binlog 日志，将数据变更以 JSON 格式写入 Kafka、Kinesis 等流处理平台。

↓ 下载 |
⚝ 源码 / 社区 |
☝ 快速开始 |
☷ 参考文档

适用场景

• 各类 ETL 数据同步需求
• 维护数据库全量变更审计日志
• 缓存构建与失效管理
• 搜索索引更新
• 服务间数据通信

工作示例

  mysql> update `test`.`maxwell` set mycol = 55, daemon = 'Stanislaw Lem';  
  maxwell -> kafka：  
  {  
    "database": "test",  
    "table": "maxwell",  
    "type": "update",  
    "ts": ***,  
    "data": { "id":1, "daemon": "Stanislaw Lem", "mycol": 55 },  
    "old": { "mycol": 23, "daemon": "what once was" }  
  }