diff options
| author | David Arthur <mumrah@gmail.com> | 2013-06-01 00:08:16 -0400 |
|---|---|---|
| committer | David Arthur <mumrah@gmail.com> | 2013-06-01 00:10:47 -0400 |
| commit | acd388e4eab100b5cf23481780f0d836ca0c21fd (patch) | |
| tree | dd21e726de91356689c6063057199418b7b16f2c /kafka/client.py | |
| parent | 2c257eeb1f02748840a8f4535d8d2a88ef5235f2 (diff) | |
| download | kafka-python-issue-26.tar.gz | |
Starting work on fixing offset commitsissue-26
* Update the "public" offset before yielding the message
* Add an option to SimpleConsumer.commit that excludes the current
offset
Ref #26
Diffstat (limited to 'kafka/client.py')
0 files changed, 0 insertions, 0 deletions