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

Tue, 22 Mar 2022 05:34:16 -0700 





因为  KafkaConnectorOptions  里面没有，所有WITH 参数里面不知道如何加入了








在 2022-03-22 18:22:44，"写虫师" <nangy2...@qq.com.INVALID> 写道：
>------------------&nbsp;原始邮件&nbsp;------------------
>发件人:                                                                           
>                                             "user-zh"                         
>                                                           
><tinyshr...@163.com&gt;;
>发送时间:&nbsp;2022年3月22日(星期二) 晚上6:21
>收件人:&nbsp;"user-zh@flink.apache.org"<user-zh@flink.apache.org&gt;;
>
>主题:&nbsp;Re:flink-sql，对于kafka 的一些额外参数如何配置
>
>
>
>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&gt; 写道：
>&gt;dear all :
>&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
>目前用flink1.4&nbsp;&nbsp; table api +kafka 的情况下，有各种警告，比如：
>&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
>The configuration 'partition.discovery.interval.ms' was supplied but isn't a 
>known config.
>&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
>这些额外的参数，在SQL WITH参数里面没定义，不知道各位时在哪个位置加入配置的？
>&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
>有什么建议吗？
>&gt;感谢！






















					回复