11.5.2、Canal__json解析
将canal采集mysql的日志文件存储于Kafka中，获取日志文件并解析object Demo02Canal { def main(args: Array[String]): Unit = { val env: StreamExecutionEnvironment = StreamExecutionEnvironment.getExecutionEnvironment val properties = new Properties() properties.setPro
