diff options
| author | Viktor Shlapakov <vshlapakov@gmail.com> | 2015-03-25 14:35:23 +0300 |
|---|---|---|
| committer | Viktor Shlapakov <vshlapakov@gmail.com> | 2015-03-25 14:35:23 +0300 |
| commit | fb118fb75c818a32d0bb81fe725faca0a714b580 (patch) | |
| tree | 01284283176011a8f003c7eeba4dfc8c9f486f51 /kafka/consumer/base.py | |
| parent | 9d5c93e902f093872c7475bb010f8e4a5b97aa40 (diff) | |
| download | kafka-python-fb118fb75c818a32d0bb81fe725faca0a714b580.tar.gz | |
Manageable queue.put() operation for MPConsumer processes
Diffstat (limited to 'kafka/consumer/base.py')
| -rw-r--r-- | kafka/consumer/base.py | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/kafka/consumer/base.py b/kafka/consumer/base.py index 9cdcf89..efc9404 100644 --- a/kafka/consumer/base.py +++ b/kafka/consumer/base.py @@ -25,6 +25,7 @@ MAX_FETCH_BUFFER_SIZE_BYTES = FETCH_BUFFER_SIZE_BYTES * 8 ITER_TIMEOUT_SECONDS = 60 NO_MESSAGES_WAIT_TIME_SECONDS = 0.1 +FULL_QUEUE_WAIT_TIME_SECONDS = 0.1 class Consumer(object): |