mumrah/kafka-python — pull request #103 by rdiomar (2014-01-15 20:56:13+00:00)
Title: 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.