Hi,

I've run into an issue using the old high-level consumer, and I'd like
to verify that it is indeed a bug (I'm pretty sure it is), or see if
I'm just doing something wrong.

The situation is that I have two consumers (A and B) in the same
consumer group reading from a single topic. One consumer (A) consumes
the full content of the queue, after which the other consumer (B) is
simply shut down (without having consumed anything). If I then attempt
to continue reading with the first consumer (A), it begins reading
from the start of the topic again (i.e. there is duplicate message
delivery).

What makes this particularly surprising is that it only occurs if
auto-commit is disabled, and/or if the second consumer (B) is shut
down after A has read the full contents of the topic.

A minimal test case which demonstrates this issue is available in this
gist: https://gist.github.com/gabrielreid/1d8a35bf3fb021bce27ceaab1b0e6152

Could anyone confirm that I'm not just making a silly mistake
somewhere which causes this behavior?

Assuming that this is indeed a bug, any pointers on where to look to
fix it would also be appreciated.

Thanks,

Gabriel

Reply via email to