diff options
author | Zack Dever <zack.dever@rd.io> | 2014-06-10 12:12:55 -0700 |
---|---|---|
committer | Zack Dever <zack.dever@rd.io> | 2014-08-25 12:00:19 -0700 |
commit | eecea8809ec71b889234dbd31c20e937a3de3580 (patch) | |
tree | 3715cbbf0bc76804fcd919cb3b85acbb609b2ae4 /kafka/protocol.py | |
parent | d73d1690b16ea86a9fd51056f4d149f54a4dd8f0 (diff) | |
download | kafka-python-eecea8809ec71b889234dbd31c20e937a3de3580.tar.gz |
Move fetching last known offset logic to a stand alone function.
The `Consumer` class fetches the last known offsets in `__init__` if
`auto_commit` is enabled, but it would be nice to expose this behavior
for consumers that aren't using auto_commit. This doesn't change
existing behavior, just exposes the ability to easily fetch and set the
last known offsets. Once #162 or something similar lands this may no
longer be necessary, but it looks like that might take a while to make
it through.
Diffstat (limited to 'kafka/protocol.py')
0 files changed, 0 insertions, 0 deletions