diff options
| author | Oskari Saarenmaa <os@ohmu.fi> | 2015-09-18 14:06:51 +0300 |
|---|---|---|
| committer | Oskari Saarenmaa <os@ohmu.fi> | 2015-09-18 14:06:51 +0300 |
| commit | e74a8ba4942891c62ef35f70472f10ee067f89b6 (patch) | |
| tree | 187e24f4eb26a8a7b6933f4c9d39a7b5aa4a21ae /kafka/protocol/struct.py | |
| parent | b525e1a8d63e4fcb0ede43c05739bc84c85cc79c (diff) | |
| download | kafka-python-e74a8ba4942891c62ef35f70472f10ee067f89b6.tar.gz | |
Consumers get_messages: allow blocking until some messages are received
Modified MultiProcessConsumer's and SimpleConsumer's `block` argument to
allow integer value which defines the number of messages to block for.
This allows callers to ask for a high number of messages and block only
until some of them are received. Otherwise callers would have to request
messages one by one or block for some time.
Diffstat (limited to 'kafka/protocol/struct.py')
0 files changed, 0 insertions, 0 deletions