summaryrefslogtreecommitdiff
path: root/kafka/common.py
diff options
context:
space:
mode:
authorDavid Arthur <mumrah@gmail.com>2013-10-07 14:16:13 -0700
committerDavid Arthur <mumrah@gmail.com>2013-10-07 14:16:13 -0700
commiteb2c1735f26ce11540fb92ea94817f43b9b3a798 (patch)
tree0c036a3d0691c6c7f69166bdc373fbe4e79b2705 /kafka/common.py
parentcfd9f86e60429d1f7af8bcac5849808354b8719e (diff)
parenta6c99b287b1cf9c39068be74d72150808588dd43 (diff)
downloadkafka-python-eb2c1735f26ce11540fb92ea94817f43b9b3a798.tar.gz
Merge pull request #55 from quixey/fault-tolerance
Improve fault tolerance by handling leadership election and other metadata changes Thanks, @jimjh!
Diffstat (limited to 'kafka/common.py')
-rw-r--r--kafka/common.py5
1 files changed, 5 insertions, 0 deletions
diff --git a/kafka/common.py b/kafka/common.py
index 8f3154c..6f0dd32 100644
--- a/kafka/common.py
+++ b/kafka/common.py
@@ -69,6 +69,11 @@ class ErrorMapping(object):
# Exceptions #
#################
+class FailedPayloadsException(Exception):
+ pass
+
+class ConnectionError(Exception):
+ pass
class BufferUnderflowError(Exception):
pass