It seems that Flink kafka consumer don't honor group.id while consumers are added dynamically. Lets say I have some flink kafka consumers reading from a topic and I dynamically add some new Flink kafka consumers with same group.id, kafka messages are getting duplicated to existing as well as new consumers. It violates the exactly once semantics as all the consumers belong to same consumer group.
I am of the view that its an existing issue. http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-kafka-group-question-td8185.html#none <http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-kafka-group-question-td8185.html#none> https://stackoverflow.com/questions/38639019/flink-kafka-consumer-groupid-not-working <https://stackoverflow.com/questions/38639019/flink-kafka-consumer-groupid-not-working> Is there any plan to provide the fix/support for group.id in upcoming releases? Let me know if there is any way to deal with it for now. -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
