klarna / brod / 922

79%

master: 80%

Pull #291

travis-ci

Change brod_topic_subscriber re-subscribe behaviour

Prior to this change, in case of brod_consumer restart.
Topic/Group subscribers re-subscribe with last-acked-offset + 1
as begin-offset to start fetching messages.
This resulted in re-deliveries of the messages fetched before
restart but not yet acked by message handler (async ack).
In this change, `last_offset` is added to track each partition's
progress, then only re-subscribe when ack_offset = last_offset
i.e. all previouly fetched messages are acked.

47 of 47 new or added lines in 2 files covered. (100.0%)

1996 of 2523 relevant lines covered (79.11%)

8847.98 hits per line