From a3c3a154606bda07cc8613587eb6e04b57316cb5 Mon Sep 17 00:00:00 2001 From: Thomas Dimson Date: Mon, 13 Jan 2014 16:39:06 -0800 Subject: Throw KafkaUnavailableError when no brokers available --- kafka/common.py | 4 ++++ 1 file changed, 4 insertions(+) (limited to 'kafka/common.py') 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 -- cgit v1.2.1