config.properties 示例
config.properties 示例
host=10.0.0.5
user=maxwell
password=***
producer=kafka
kafka.bootstrap.servers=10.0.0.6:9092
kafka_topic=maxwell启动
启动
bin/maxwell --config config.properties --daemon| 输入 | ROW 格式 binlog |
|---|---|
| 输出 | JSON 变更事件(含数据库、表、旧值与新值) |
| 位点 | 保存在 maxwell 库的位点表 |
| 账号 | 需要复制相关权限与 SELECT |
与 Canal/Debezium 相同:依赖 ROW 格式 binlog;升级前先确认 binlog_row_image 未被改成 MINIMAL。