xiaoHoly commented on a change in pull request #14531:
URL: https://github.com/apache/flink/pull/14531#discussion_r587193000
##########
File path:
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSourceBuilder.java
##########
@@ -423,14 +430,15 @@ private void parseAndSetRequiredProperties() {
startingOffsetsInitializer.getAutoOffsetResetStrategy().name().toLowerCase(),
true);
- // If the source is bounded, do not run periodic partition discovery.
- if (maybeOverride(
- KafkaSourceOptions.PARTITION_DISCOVERY_INTERVAL_MS.key(),
- "-1",
- boundedness == Boundedness.BOUNDED)) {
- LOG.warn(
- "{} property is overridden to -1 because the source is
bounded.",
- KafkaSourceOptions.PARTITION_DISCOVERY_INTERVAL_MS);
+ // If the source is bounded or stoppingOffsetsInitializer is
specified, do not run periodic
Review comment:
I think these should be exposed to users in the official documents
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
