[ https://issues.apache.org/jira/browse/FLINK-10342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Oleksandr Nitavskyi reopened FLINK-10342: ----------------------------------------- > Kafka duplicate topic consumption when topic name is changed > ------------------------------------------------------------ > > Key: FLINK-10342 > URL: https://issues.apache.org/jira/browse/FLINK-10342 > Project: Flink > Issue Type: Bug > Reporter: Oleksandr Nitavskyi > Assignee: Oleksandr Nitavskyi > Priority: Minor > > In case of topic name is simply renamed for a KafkaConsumer Flink starts to > consume from old and a new topic in the same time which can lead to > unexpected behavior. > Here is the PR with reproduce: https://github.com/apache/flink/pull/6691 > -- This message was sent by Atlassian JIRA (v7.6.3#76005)