基于canal+kafka+flink实现实时增量同步4:kafka消息入库到MySQL功能演示一、新建三个表二、要实现的功能说明三、功能演示
一、新建三个表(1)主表user_id。它包含有主键user_idCREATE TABLE `user_id` ( `user_id` int(11) NOT NULL, `name` varchar(255) CHARACTER SET utf8 COLLATE utf8_general_ci DEFAULT NULL, `age` int(11) DEFAULT NULL, `user_info_id` int(11) DEFAULT NULL, PRIMARY KEY