Maxwell1.29.x 发送数据到kafka - 测试

启动 kafka 可视化工具

kafka可视化工具 offset explorer

插入数据

一条语句插入一条记录

执行下面sql:

INSERT INTO `scott`.`dept`(`deptno`, `dname`, `loc`) VALUES (60, '测试部', 'NEW YORK');

ffset explorer 查看数据如下:

一条语句插入多条记录

执行下面sql:

INSERT INTO `scott`.`dept`(`deptno`, `dname`, `loc`) VALUES (71, '财务部', '上海'),(72,'HR','北京'),(73,'销售部','广州');

maxwell控制台打印如下:

{"database":"scott","table":"dept","type":"insert","ts":1655129301,"xid":133957,"xoffset":0,"data":{"deptno":71,"dname":"财务部","loc":"上海"}}
{"database":"scott","table":"dept","type":"insert","ts":1655129301,"xid":133957,"xoffset":1,"data":{"deptno":72,"dname":"HR","loc":"北京"}}
{"database":"scott","table":"dept","type":"insert","ts":1655129301,"xid":133957,"commit":true,"data":{"deptno":73,"dname":"销售部","loc":"广州"}}

结论:虽然一条sql插入多条记录,但在maxwell中,仍然是3条记录

修改数据

执行下面sql:

update dept set loc='杭州' where deptno = 73

maxwell打印结果如下:

{
    "database":"scott",
    "table":"dept",
    "type":"update",       # 操作类型
    "ts":1655129798,
    "xid":135261,
    "commit":true,
    "data":{              # 当前数据
        "deptno":73,      # 当前 deptno 字段值
        "dname":"销售部",  # 当前 dname 字段值
        "loc":"杭州"       # 当前 loc 字段值
    },
    "old":{                # 原数据
        "loc":"广州"       # 原loc字段值
    }
}

删除数据

delete from dept where deptno = 73

maxwell打印结果如下:

{
    "database":"scott",
    "table":"dept",
    "type":"delete",       # 操作类型
    "ts":1655130059,
    "xid":135968,
    "commit":true,
    "data":{               # 数据部分
        "deptno":73,
        "dname":"销售部",
        "loc":"杭州"
    }
}

原文出处:/show_1IX3UuyG3sK0.html