[
https://issues.apache.org/jira/browse/FLINK-30490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17700942#comment-17700942
]
Ruibin Xing edited comment on FLINK-30490 at 3/16/23 3:05 AM:
--------------------------------------------------------------
hi, we are encountering the same issue and are actively working on this.
was (Author: JIRAUSER299280):
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)
