回复： Flink-kafka-connector Consumer配置警告

[飞翔]

你可以看下源码：



这个props只是作为FlinkKafkaConsumer初始化配置变量，只是这个props 
不仅仅是用来初始化kafka的，只不过这个props最后整个扔进kafka消费客户端的初始化里面而已，不会有任何影响。
就想你自己初始化一个kafka 消费端，你往props塞进其他参数，也会警告，但没有任何影响。


--原始邮件--
发件人:
"user-zh"   
 
https://ci.apache.org/projects/flink/flink-docs-stable/dev/connectors/kafka.html#topic-discovery介绍：
 By default, partition discovery is disabled. To enable it, set a
 non-negative value for flink.partition-discovery.interval-millis in the
 provided properties config, representing the discovery interval in
 milliseconds.
 
 
 上述配置应该是合法的，但是为何会报如此警告呢？
 
 
 
 --
 Sent from: http://apache-flink.147419.n8.nabble.com/

回复：现在的flink1.12支持批流混合的作业吗？

[飞翔]

哈哈，建议你去了解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/

回复：mysql cdc配置问题求助

[飞翔]

第一：一般这里需要reload 和lock table权限，这个权限包括你的replication slave 
等权限用grant是授予不了的，测试建议先all。 第二：你可以登陆安装目录flink1.x/log,里面有详细的错误日志，不要只在client 
里面苦想。我们连接的是mysql-cdc



发自我的iPhone


-- 原始邮件 --
发件人: 信华哺