Re:flink-sql，对于kafka 的一些额外参数如何配置

Tue, 22 Mar 2022 03:22:08 -0700 

Hi，
partition.discovery.interval.ms 这个是Flink connector 
kafka里面加上的，KafkaSourceOptions里面定义的，
看下你的kafka-client的版本，官方的是 2.4.1，如果版本一样，那只能先忽略了。





在 2022-03-22 17:10:52，"Michael Ran" <greemqq...@163.com> 写道：
>dear all :
>             目前用flink1.4   table api +kafka 的情况下，有各种警告，比如：
>             The configuration 'partition.discovery.interval.ms' was supplied 
> but isn't a known config.
>             这些额外的参数，在SQL WITH参数里面没定义，不知道各位时在哪个位置加入配置的？
>             有什么建议吗？
>感谢！

回复