All Our kafka consumer has the group.id property but when we receive messages on the channel when not connect and then reconnect we don't get the message.
The kafka console consumer when running "-group testben" works perfectly fine. Is there some other place to setup flink to read from the latest offset?