[FLINK-28454] Fix the wrong timestamp example of KafkaSource

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.13.6, 1.14.5, 1.15.1
• Fix Version/s: 1.16.0, 1.15.2, 1.14.6
• Component/s: Connectors / Kafka, Documentation
• Labels: pull-request-available
• Assignee: Rui Fan
• Reporter: Rui Fan
• Created: 08/Jul/22 05:05
• Updated: 13/Jul/22 08:39
• Resolved: 13/Jul/22 07:43

Description

https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/connectors/datastream/kafka/

 

The timestamp unit of startingOffset is second in kafkaSource doc, but it should be milliseconds. It will mislead flink users.

 

 

 

It should be milliseconds, because the timestamp is used in  OffsetSpec.fromTimestamp() , and the comment is : @param timestamp in milliseconds

 

By the way, the timestamp is milliseconds in old source doc. link: https://nightlies.apache.org/flink/flink-docs-release-1.13/docs/connectors/datastream/kafka/#kafka-consumers-start-position-configuration

 

 

 

 

 

Issue Links

• is caused by: FLINK-22722 Add Documentation for Kafka New Source
• links to: GitHub Pull Request #20214