[FLINK-24456] Support bounded offset in the Kafka table connector

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.17.0
• Component/s: Connectors / Kafka, Table SQL / Ecosystem
• Labels: pull-request-available stale-assigned
• Assignee: Dawid Wysakowicz
• Reporter: Haohui Mai
• Created: 06/Oct/21 03:19
• Updated: 12/Apr/23 17:07
• Resolved: 31/Jan/23 22:54

Description

The setBounded API in the DataStream connector of Kafka is particularly useful when writing tests. Unfortunately the table connector of Kafka lacks the same API.

It would be good to have this API added.

Issue Links

• duplicates: FLINK-29951 Kafka SQL connector supports setting end offset/timestamp
• duplicates: FLINK-26954 Support Kafka bounded read in TableAPI
• links to: GitHub Pull Request #17994
• links to: GitHub Pull Request #21808

Sub-Tasks

• Support bounded timestamp in kafka table connector: Open