diff options
| author | Enrico Canzonieri <ecanzonieri@gmail.com> | 2015-01-06 17:33:21 +0100 |
|---|---|---|
| committer | Enrico Canzonieri <enrico@yelp.com> | 2015-01-14 15:13:33 -0800 |
| commit | 878e4cefb696547d76f2eb0ad5b7afd2b1cfe044 (patch) | |
| tree | 7ad6a258d4dcf0d59bcc532cb09420416087bd99 /kafka/common.py | |
| parent | 02c2b469003e2ddcb051dbb4d95977137050c19f (diff) | |
| download | kafka-python-878e4cefb696547d76f2eb0ad5b7afd2b1cfe044.tar.gz | |
Implement offsets reset when OffsetOutOfRangeError
This slightly changes the SimpleConsumer interface adding the default
option use_latest_offsets. The fetch behaviour is also changed since it
does not raise OffsetOutOfRangeError anymore. Resetting the offsets
automatically is especially useful in MultiprocessConsumer, where an
explicit seek call is not possible.
Diffstat (limited to 'kafka/common.py')
0 files changed, 0 insertions, 0 deletions