Maxwell1.29.x 启动,监控数据改变、打印到控制台

说明

本文讲解启动的两种方式,这里只是演示,将改变的数据 打印到控制台上

真正使用是 发送到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

原文出处:/show_1IX3UKaWpxBw.html