summaryrefslogtreecommitdiff
path: root/kafka/common.py
diff options
context:
space:
mode:
authorThomas Dimson <tdimson@gmail.com>2014-01-13 16:39:06 -0800
committerThomas Dimson <tdimson@gmail.com>2014-01-13 16:39:06 -0800
commita3c3a154606bda07cc8613587eb6e04b57316cb5 (patch)
treeb0c597a730c0a9e79a20100c015d46b409d17c3c /kafka/common.py
parent9c7b41283851735cbee5092f2923d7c8a006b89a (diff)
downloadkafka-python-a3c3a154606bda07cc8613587eb6e04b57316cb5.tar.gz
Throw KafkaUnavailableError when no brokers available
Diffstat (limited to 'kafka/common.py')
-rw-r--r--kafka/common.py4
1 files changed, 4 insertions, 0 deletions
diff --git a/kafka/common.py b/kafka/common.py
index 5bd9a96..c0a1a6a 100644
--- a/kafka/common.py
+++ b/kafka/common.py
@@ -78,6 +78,10 @@ class KafkaRequestError(KafkaError):
pass
+class KafkaUnavailableError(KafkaError):
+ pass
+
+
class BrokerResponseError(KafkaError):
pass