[
https://issues.apache.org/jira/browse/FLINK-30490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hilmi Al Fatih updated FLINK-30490:
-----------------------------------
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|#:~: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.
was:
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.
> 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|#:~: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)
