[jira] [Closed] (FLINK-34089) Missing check of subscribed and assigned topics at job startup

["Martijn Visser (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLINK-34089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Martijn Visser closed FLINK-34089.
----------------------------------
    Resolution: Won't Fix

If users want to remove a topic from their job, they should change their savepoint file. Just removing an input topic has implications on your pipeline, and users shouldn't just do that. 

If users have a requirement to (dynamically) add or remove Kafka topics, they should use the solution that has been brought forward with https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=217389320

> Missing check of subscribed and assigned topics at job startup
> --------------------------------------------------------------
>
>                 Key: FLINK-34089
>                 URL: https://issues.apache.org/jira/browse/FLINK-34089
>             Project: Flink
>          Issue Type: Bug
>          Components: Connectors / Kafka
>    Affects Versions: kafka-3.0.2
>            Reporter: tanjialiang
>            Priority: Major
>              Labels: pull-request-available
>
> When we unsubscribe a topic and still restore from the old state, the job will still read data from the unsubscribed topic. I think we should check if that the subscribed topic partitions match the assigned partitions, and throw an error so the user can handle it.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)