说明
本文讲解启动的两种方式,这里只是演示,将改变的数据 打印到控制台上
真正使用是 发送到kafka中
准备
cd /program/maxwell-1.29.2
启动方式一:命令行
启动命令后面带很多参数:
bin/maxwell --user='maxwell' --password='maxwell' --host='hadoop1' --producer=stdout
解释:
--user='maxwell':指定用户名--password='maxwell':指定密码--host='hadoop1':指定数据库ip 或 主机名--producer=stdout:生产者模式,有2个值:- stdout:控制台
- kafka:kafka集群
测试
执行下面sql:
INSERT INTO `scott`.`dept`(`deptno`, `dname`, `loc`) VALUES (60, '测试部', 'NEW YORK');
查看控制台,显示如下:
{"database":"scott","table":"dept","type":"insert","ts":1655083406,"xid":15969,"commit":true,"data":{"deptno":50,"dname":"大数据部","loc":"北京"}}
{"database":"scott","table":"dept","type":"insert","ts":1655083431,"xid":16035,"commit":true,"data":{"deptno":60,"dname":"测试部","loc":""}}
{"database":"scott","table":"dept","type":"update","ts":1655083447,"xid":16096,"commit":true,"data":{"deptno":60,"dname":"测试部","loc":"NEW YORK"},"old":{"loc":""}}
退出
ctrl+c
启动方式二:配置文件
复制配置文件
cp config.properties.example config.properties
修改配置文件
vim config.properties
修改下面内容:
producer=stdout
host=hadoop1
启动
bin/maxwell --config ./config.properties
测试
执行下面sql:
INSERT INTO `scott`.`dept`(`deptno`, `dname`, `loc`) VALUES (70, '财务部', '上海');
查看控制台,显示如下:
{"database":"scott","table":"dept","type":"insert","ts":1655084126,"xid":17360,"commit":true,"data":{"deptno":70,"dname":"财务部","loc":"上海"}}
退出
ctrl+c