[ https://issues.apache.org/jira/browse/FLINK-32717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17749108#comment-17749108 ]
Martijn Visser commented on FLINK-32717: ---------------------------------------- If you're restarting from a checkpoint/savepoint, that is expected. The `setTopics` is only followed when starting from a clean job. If you don't want this, you currently have to start with a clean state. The situation is expected to be improved with https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=217389320 > Change of topic list from KafkaSource not works > ----------------------------------------------- > > Key: FLINK-32717 > URL: https://issues.apache.org/jira/browse/FLINK-32717 > Project: Flink > Issue Type: Improvement > Reporter: Kwangin (Dennis) Jung > Priority: Minor > > I've setup 'KafkaSource' as following: > > {code:java} > KafkaSource.<T>builder().setTopics("A", "B")...{code} > > and later, removed 1 topic from list as following and restart application. > > {code:java} > KafkaSource.<T>builder().setTopics("B")...{code} > > But application still ingest data from topic 'A'. > * Is this expected? > * If it is, how can I stop ingesting data from removed topic? > -- This message was sent by Atlassian Jira (v8.20.10#820010)