场景应用：将MySQL的变化数据转为实时流输出到Kafka中。 注意版本问题，版本不同可能会出现异常，以下版本测试没问题： flink1.12.7 flink-connector-mysq ...

该方法使用的是com.ververica版本的flink-connector-mysql-cdc，另一个版本测试也没问题了，见https://www.cnblogs.com/30go/p/157733 ...

之前测试环境用root没这个问题。换到生产环境指定的某个mysql账号出现权限不足： 需要修改：这类权限的授权不是针对某个数据库的，因此须使用on *.*来进行： 会遇到一系列权限 ...