canal.json数据只能读取数据,不能写数据
使用canal监听mysql的binlog日志,mysql表数据变化,日志写入kafka中
使用flink读取kafka实时计算数据,写到mysql中
mysql->canal(json格式)->kafka->flink(读json格式)->mysql

canal.json数据只能读取数据,不能写数据
使用canal监听mysql的binlog日志,mysql表数据变化,日志写入kafka中
使用flink读取kafka实时计算数据,写到mysql中
mysql->canal(json格式)->kafka->flink(读json格式)->mysql