twalthr commented on code in PR #21808: URL: https://github.com/apache/flink/pull/21808#discussion_r1091852964
########## docs/content.zh/docs/connectors/table/kafka.md: ########## @@ -485,6 +510,22 @@ ROW<`version` INT, `behavior` STRING> 如果使用了 `specific-offsets`，必须使用另外一个配置项 `scan.startup.specific-offsets` 来为每个 partition 指定起始偏移量， 例如，选项值 `partition:0,offset:42;partition:1,offset:300` 表示 partition `0` 从偏移量 `42` 开始，partition `1` 从偏移量 `300` 开始。 +### Bounded Ending Position + +The config option `scan.bounded.mode` specifies the bounded mode for Kafka consumer. The valid enumerations are: +<ul> +<li><span markdown="span">`group-offsets`</span>: bounded from committed offsets in ZK / Kafka brokers of a specific consumer group.</li> +<li><span markdown="span">`latest-offset`</span>: bounded from the latest offset.</li> +<li><span markdown="span">`timestamp`</span>: bounded from user-supplied timestamp for each partition.</li> +<li><span markdown="span">`specific-offsets`</span>: bounded from user-supplied specific offsets for each partition.</li> +</ul> + +If config option value `scan.bounded.mode` is not set the default is an unbounded data stream. + +If `timestamp` is specified, another config option `scan.bounded.timestamp-millis` is required to specify a specific bounded timestamp in milliseconds since January 1, 1970 00:00:00.000 GMT. Review Comment: > Prior to 1972, this time was called Greenwich Mean Time (GMT) nevermind -- 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. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
