aljoscha commented on a change in pull request #12147:
URL: https://github.com/apache/flink/pull/12147#discussion_r425657495
##########
File path:
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java
##########
@@ -273,6 +273,36 @@ static void adjustAutoCommitConfig(Properties properties,
OffsetCommitMode offse
// Configuration
//
------------------------------------------------------------------------
+ /**
+ * Sets the given {@link WatermarkStrategy} on this consumer. These
will be used to assign
+ * timestamps to records and generates watermarks to signal event time
progress.
+ *
+ * <p>When a subtask of a FlinkKafkaConsumer source reads multiple
Kafka partitions,
Review comment:
good catch! I just copied the existing text, will change.
----------------------------------------------------------------
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:
[email protected]
