diff options
Diffstat (limited to 'kafka/consumer.py')
| -rw-r--r-- | kafka/consumer.py | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/kafka/consumer.py b/kafka/consumer.py index bead1dd..5d2775d 100644 --- a/kafka/consumer.py +++ b/kafka/consumer.py @@ -33,10 +33,10 @@ class FetchContext(object): self.consumer = consumer self.block = block - if block and not timeout: - timeout = FETCH_DEFAULT_BLOCK_TIMEOUT - - self.timeout = timeout * 1000 + if block: + if not timeout: + timeout = FETCH_DEFAULT_BLOCK_TIMEOUT + self.timeout = timeout * 1000 def __enter__(self): """Set fetch values based on blocking status""" |