[ https://issues.apache.org/jira/browse/FLINK-10342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Dawid Wysakowicz updated FLINK-10342: ------------------------------------- Priority: Blocker (was: Major) > 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: Feng LI > Priority: Blocker > Fix For: 1.8.0 > > > 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)