Fix offset increments

* Increment the offset before returning a message rather than when putting it in the internal queue. This prevents committing the wrong offsets.
* In MultiProcessConsumer, store the offset of the next message to be read, since that's what self.offsets is intended for.