auto.offset.reset=latest not working about cppkafka

[mfontanini]

I just tried this and it works as expected, I'm using rdkafka 0.9.5. Keep in mind that the offset reset policy just means "if there is not an offset for this consumer in this topic/partition, then use this policy". This means that if you do this:

• Start consuming
• Produce 1 message
• Consumer sees the message and commits it
• Stop consumer
• Produce 1 message
• Start consumer

Then the consumer will see that one new message because it did have an offset but this new message has an offset larger than the last committed one, hence you receive the message.

[fmvin]

Thanks a lot for explaination.
When please advice an appropriate solution how to consume only these messages which are produced after consumer starts.

[mfontanini]

You can just not commit any messages and use reset policy latest. That way there's never an offset committed for a topic/partition for that consumer, hence every time you'll start at the end of each queue.

[fmvin]

You can just not commit any messages and use reset policy latest. That way there's never an offset committed for a topic/partition for that consumer, hence every time you'll start at the end of each queue.

It works now as I expected. Thanks a lot.