diff options
| author | Omar Ghishan <omar.ghishan@rd.io> | 2014-01-15 14:28:48 -0800 |
|---|---|---|
| committer | Omar Ghishan <omar.ghishan@rd.io> | 2014-01-15 16:26:15 -0800 |
| commit | 8cc36dd7a1c7691e5c26b47cb667bc48054594a0 (patch) | |
| tree | e8244038c2394748bfac12799b23bf7548d9bc94 /example.py | |
| parent | c36cb618d2ba5fcba118dd8b87bf51f26074c8f1 (diff) | |
| download | kafka-python-8cc36dd7a1c7691e5c26b47cb667bc48054594a0.tar.gz | |
Store fetched offsets separately.
Fetch requests can be repeated if we get a ConsumerFetchSizeTooSmall
or if _fetch() is called multiple times for some reason. We don't want
to re-fetch messages that are already in our queue, so store the offsets
of the last enqueued messages from each partition.
Diffstat (limited to 'example.py')
0 files changed, 0 insertions, 0 deletions