diff options
| -rw-r--r-- | kafka/client_async.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/kafka/client_async.py b/kafka/client_async.py index c3fcc79..bf395c5 100644 --- a/kafka/client_async.py +++ b/kafka/client_async.py @@ -545,7 +545,7 @@ class KafkaClient(object): elif timeout_ms is None: timeout_ms = self.config['request_timeout_ms'] elif not isinstance(timeout_ms, (int, float)): - raise RuntimeError('Invalid type for timeout: %s' % type(timeout_ms)) + raise TypeError('Invalid type for timeout: %s' % type(timeout_ms)) # Loop for futures, break after first loop if None responses = [] |