diff options
| author | Jim Lim <jim@quixey.com> | 2013-09-27 14:02:10 -0700 |
|---|---|---|
| committer | Jim Lim <jim@quixey.com> | 2013-10-04 14:49:44 -0700 |
| commit | a6c99b287b1cf9c39068be74d72150808588dd43 (patch) | |
| tree | 0c036a3d0691c6c7f69166bdc373fbe4e79b2705 /kafka/common.py | |
| parent | cfd9f86e60429d1f7af8bcac5849808354b8719e (diff) | |
| download | kafka-python-a6c99b287b1cf9c39068be74d72150808588dd43.tar.gz | |
make changes to be more fault tolerant: clean up connections, brokers, failed_messages
- add integration tests for sync producer
- add integration tests for async producer w. leadership election
- use log.exception
Diffstat (limited to 'kafka/common.py')
| -rw-r--r-- | kafka/common.py | 5 |
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 |