Sorry for the delayed response. I passed the consumeMessage to downstream handlers and mark message as processed if no error is encountered. So if app crashed and restarted, we would start from the last uncommitted message and 'process at least once'. But be clear that Sarama commits offsets asynchronously, you can use this to commit manually but sacrifice some performance: https://github.com/Shopify/sarama/pull/1699/files