Broadway experiment using a custom `GenStage` producer with partitioning which stops processing on message failure - View it on GitHub