summaryrefslogtreecommitdiff
path: root/kafka/common.py
diff options
context:
space:
mode:
authormrtheb <mrlabbe@gmail.com>2014-02-15 11:00:35 -0500
committermrtheb <mrlabbe@gmail.com>2014-02-15 11:00:35 -0500
commit5e5d7097a70e79d90d573aef6a0adba40ada5f03 (patch)
treece12705aaa9ad1bd77d2a65709cd2b43d0fd86e0 /kafka/common.py
parentb253166bec5a7d836767523b1ad5275eeed6b83f (diff)
downloadkafka-python-5e5d7097a70e79d90d573aef6a0adba40ada5f03.tar.gz
Changes based on comments by @rdiomar, plus added LeaderUnavailableError for clarity
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 ec0b89b..b4fe5c7 100644
--- a/kafka/common.py
+++ b/kafka/common.py
@@ -82,6 +82,10 @@ class BrokerResponseError(KafkaError):
pass
+class LeaderUnavailableError(KafkaError):
+ pass
+
+
class PartitionUnavailableError(KafkaError):
pass