Hi and thanks for this great library(-ies),
we use the alpakka Kafka connector in our project to consume messages from Apache Kafka and are currently investigating " unexpected consumer offset reset" as you have mentioned in Unexpected-consumer-offset-reset.
All our consumers are configured with auto-reset: earliest and explicit committing, but are also wrapped into RestartSources (see Restarting the stream with a backoff stage) causing the re-consumption of a lot of messages once an unexpected offset reset happens.
We would like to use the provided offset-reset-protection but are not sure if it can work within a RestartSource. Could you please elaborate if this is a valid approach here?