[FLINK-30490] Deleted topic from KafkaSource is still included in subsequent restart from savepoint

• Type: New Feature
• Status: Closed
• Priority: Minor
• Resolution: Duplicate
• Component/s: Connectors / Kafka
• Assignee: Unassigned
• Reporter: Hilmi Al Fatih
• Created: 23/Dec/22 05:56
• Updated: 16/Oct/23 15:48
• Resolved: 16/Oct/23 15:48

Description

It seems that KafkaSource does not handle the removed topic partitions after restarting from offset. So far is still commented out as TODO. (ref)

I am wondering if there is an exact plan on when this will be done, what are technical consideration, etc. Since I really need this feature, I would really love to contribute under guidance from maintaner.

Issue Links

• is duplicated by: FLINK-31483 Implement Split Deletion Support in Flink Kafka Connector