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

["Ruibin Xing (Jira)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/FLINK-30490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17700942#comment-17700942 ] 

Ruibin Xing commented on FLINK-30490:
-------------------------------------

hi, we are encountering the same issue and are actively working on this.
 
 
 

 

> 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
>            Priority: Minor
>
> 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)