summaryrefslogtreecommitdiff
path: root/kafka/protocol.py
diff options
context:
space:
mode:
authorZack Dever <zack.dever@rd.io>2014-06-10 12:12:55 -0700
committerZack Dever <zack.dever@rd.io>2014-08-25 12:00:19 -0700
commiteecea8809ec71b889234dbd31c20e937a3de3580 (patch)
tree3715cbbf0bc76804fcd919cb3b85acbb609b2ae4 /kafka/protocol.py
parentd73d1690b16ea86a9fd51056f4d149f54a4dd8f0 (diff)
downloadkafka-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