diff options
| author | Dana Powers <dana.powers@rd.io> | 2016-01-02 13:18:10 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2016-01-02 13:18:10 -0800 |
| commit | 24a4c2a7c5a1265899316aca86a1149496d6564e (patch) | |
| tree | a917f505c3bd05284c2ac7aefbf99da04cf77503 /kafka/client_async.py | |
| parent | 976970f89acfdb3582feed613722158004b0ff3e (diff) | |
| download | kafka-python-24a4c2a7c5a1265899316aca86a1149496d6564e.tar.gz | |
Improve iterator interface
- Support single message consumption via next(consumer) in py2/py3
- batch message methods (Fetcher.fetched_records / KafkaConsumer.poll)
are incompatible with iterators -- message generator state keeps
messages internally after they are popped from _records, but before
subscription_state is updated.
Diffstat (limited to 'kafka/client_async.py')
0 files changed, 0 insertions, 0 deletions