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?

Reply via email to