diff options
| author | Omar Ghishan <omar.ghishan@rd.io> | 2014-01-15 11:13:59 -0800 |
|---|---|---|
| committer | Omar Ghishan <omar.ghishan@rd.io> | 2014-01-15 11:13:59 -0800 |
| commit | c36cb618d2ba5fcba118dd8b87bf51f26074c8f1 (patch) | |
| tree | edb10f23221e7cf5a8ca1ffb62f7a8195283ecfa /example.py | |
| parent | 9644166048d6fe1cdbd1fc3096329ee2142b147e (diff) | |
| download | kafka-python-c36cb618d2ba5fcba118dd8b87bf51f26074c8f1.tar.gz | |
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
Diffstat (limited to 'example.py')
0 files changed, 0 insertions, 0 deletions