Be able to consume messages from a start to an end offset via MultiProcessConsumer