[ https://issues.apache.org/jira/browse/FLINK-32717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17750276#comment-17750276 ]
Kwangin (Dennis) Jung edited comment on FLINK-32717 at 8/2/23 11:55 AM: ------------------------------------------------------------------------ [~martijnvisser] got it. Thanks for following-up. was (Author: JIRAUSER301448): [~martijnvisser] thanks for following-up > 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)