Examples/Guidance for Manually Handling ResetInvalidOffsets Instead of Using the Default

[dharmjit]

Hi Folks, I recently encountered OffsetOutOfRange errors in my service. Since I was using Consumer.Offsets.Initial = sarama.OffsetNewest, the offset reset caused a significant loss of messages, which we only discovered later. I’m looking for general guidance on handling these scenarios and any examples of how application code can manually manage offset resets to prevent message loss.

[dharmjit]

@dnwe sorry for tagging you but if you can provide any inputs on this please. Thanks!