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

• Type: New Feature
• Status: Open
• Priority: Minor
• Resolution: Unresolved
• Component/s: Connectors / Kafka
• Assignee: Unassigned
• Reporter: Hilmi Al Fatih
• Created: 23/Dec/22 05:56
• Updated: 16/Mar/23 06:25

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.