[FLINK-29951] Kafka SQL connector supports setting end offset/timestamp

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Duplicate
• Affects Version/s: 1.17.0
• Component/s: Connectors / Kafka
• Assignee: Unassigned
• Reporter: Xuannan Su
• Created: 09/Nov/22 06:39
• Updated: 18/Oct/24 19:36
• Resolved: 09/Nov/22 07:47

Description

Currently, KafkaSource at DataStream API allows specifying end offset/timestamp by `KafkaSourceBuilder#setBounded`, while Kafka SQL connector has no way to do that.

To better align the functionality with DataStream and support bounded stream, we want to support setting end offset/timestamp in Kafka SQL connector.

Issue Links

• is duplicated by: FLINK-24456 Support bounded offset in the Kafka table connector