[ 
https://issues.apache.org/jira/browse/FLINK-20777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17255865#comment-17255865
 ] 

jiawen xiao commented on FLINK-20777:
-------------------------------------

Yes ,i know what your said.

In my opinion, Turning off dynamic partition by default is the design idea. 
Under this premise, the default value of property 
"partition.discovery.interval.ms"  is only for reference.

WDYT?

> Default value of property "partition.discovery.interval.ms" is not as 
> documented in new Kafka Source
> ----------------------------------------------------------------------------------------------------
>
>                 Key: FLINK-20777
>                 URL: https://issues.apache.org/jira/browse/FLINK-20777
>             Project: Flink
>          Issue Type: Bug
>          Components: Connectors / Kafka
>            Reporter: Qingsheng Ren
>            Priority: Major
>             Fix For: 1.12.1
>
>
> The default value of property "partition.discovery.interval.ms" is documented 
> as 30 seconds in {{KafkaSourceOptions}}, but it will be set as -1 in 
> {{KafkaSourceBuilder}} if user doesn't pass in this property explicitly. 



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to