哈哈,建议你去了解flink-cdc
发自我的iPhone
-- 原始邮件 --
发件人: 键盘击打者 http://apache-flink.147419.n8.nabble.com/file/t1425/1617266981%281%29.jpg;
祝好,
耳朵
--
Sent from: http://apache-flink.147419.n8.nabble.com/
第一:一般这里需要reload 和lock table权限,这个权限包括你的replication slave
等权限用grant是授予不了的,测试建议先all。 第二:你可以登陆安装目录flink1.x/log,里面有详细的错误日志,不要只在client
里面苦想。我们连接的是mysql-cdc
发自我的iPhone
-- 原始邮件 --
发件人: 信华哺
你可以看下源码:
这个props只是作为FlinkKafkaConsumer初始化配置变量,只是这个props
不仅仅是用来初始化kafka的,只不过这个props最后整个扔进kafka消费客户端的初始化里面而已,不会有任何影响。
就想你自己初始化一个kafka 消费端,你往props塞进其他参数,也会警告,但没有任何影响。
--原始邮件--
发件人: