[FLINK-32289] The metadata column type is incorrect in Kafka table connector example

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.15.4, 1.16.2, 1.17.1
• Fix Version/s: 1.18.0, kafka-3.1.0
• Component/s: Connectors / Kafka
• Labels: pull-request-available
• Assignee: yux
• Reporter: Leonard Xu
• Created: 08/Jun/23 09:10
• Updated: 25/Jan/24 21:57
• Resolved: 13/Jun/23 14:11

Description

The example[1] defined ts column with TIMESTAMP type

 

  `ts` TIMESTAMP(3) METADATA FROM 'timestamp'

the correct column type should be TIMESTAMP_LTZ type.

 

 `ts` TIMESTAMP_LTZ(3) METADATA FROM 'timestamp'  

 

[1] https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/connectors/table/kafka/#how-to-create-a-kafka-table

Issue Links

• links to: GitHub Pull Request #32
• links to: GitHub Pull Request #22760