You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by Michael Ran <gr...@163.com> on 2022/03/22 09:10:52 UTC

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

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

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

Posted by Michael Ran <gr...@163.com>.





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








在 2022-03-22 18:22:44，"写虫师" <na...@qq.com.INVALID> 写道：
>------------------&nbsp;原始邮件&nbsp;------------------
>发件人:                                                                                                                        "user-zh"                                                                                    <tinyshrimp@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" <greemqqran@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;感谢！

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

Posted by 写虫师 <na...@qq.com.INVALID>.
------------------&nbsp;原始邮件&nbsp;------------------
发件人:                                                                                                                        "user-zh"                                                                                    <tinyshrimp@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" <greemqqran@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;感谢！

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

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





在 2022-03-22 17:10:52，"Michael Ran" <gr...@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参数里面没定义，不知道各位时在哪个位置加入配置的？
>             有什么建议吗？
>感谢！