diff options
| author | Dana Powers <dana.powers@rd.io> | 2015-12-28 15:05:08 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2015-12-28 15:18:43 -0800 |
| commit | baab076c7e70a721d958f588c4199acbaae41481 (patch) | |
| tree | 4a5db85a6c55f480272745d878fe524de0f56718 /kafka/common.py | |
| parent | 9820c5d55398bdb49ffbcd0e6a997bde9f8891fe (diff) | |
| download | kafka-python-baab076c7e70a721d958f588c4199acbaae41481.tar.gz | |
AbstractCoordinator (modelled after upstream Java class)
- Heartbeat class manages HeartbeatRequest / Response state
- metrics are still TODO
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 33f24a4..597fb5c 100644 --- a/kafka/common.py +++ b/kafka/common.py @@ -111,6 +111,11 @@ class DisconnectError(KafkaError): invalid_metadata = True +class NoBrokersAvailable(KafkaError): + retriable = True + invalid_metadata = True + + class NodeNotReadyError(KafkaError): retriable = True |