Lorenzo Benvenuti

I had a quick look at the code, as far as I can see `aiokafka` _doesn't_ commit the offset but it keeps increasing the value in memory (see `FetchResult._update_position`) regardless...

Thanks for your feedback! As I mentioned in the Jira US, I had a few ideas about how to handle errors without stopping the route. I've pushed some changes with...

I've added a couple of integration tests and moved the `fallbackToLatestReplayId` to the endpoint (I thought it was a better option in case someone has multiple subscribers and wants to...

I've updated the PR, using `main` as the target branch, and addressed the comments. Thanks!