Hilmi Al Fatih created FLINK-30490:
--------------------------------------
Summary: Deleted topic from KafkaSource is still included in
subsequent restart from savepoint
Key: FLINK-30490
URL: https://issues.apache.org/jira/browse/FLINK-30490
Project: Flink
Issue Type: New Feature
Components: Connectors / Kafka
Reporter: Hilmi Al Fatih
It seems that KafkaSource does not handle the removed topic partitions after
restarting from offset. So far is still commented out as TODO.
([ref|[https://github.com/apache/flink/blob/master/flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumerator.java#:~:text=//%20TODO%3A%20Handle%20removed%20partitions.])]
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.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
