You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Hilmi Al Fatih (Jira)" <ji...@apache.org> on 2022/12/23 05:57:00 UTC

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

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)