diff options
| author | Dana Powers <dana.powers@rd.io> | 2015-12-20 10:19:11 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2015-12-28 13:09:59 -0800 |
| commit | cda2e17cd115f76f4992a34bab2b684ed08d4fef (patch) | |
| tree | bc22ca02fd2001bef8382f2814917223246b7039 /kafka/common.py | |
| parent | d203b900eafbe8153e0cb3411ea25adebb827bf7 (diff) | |
| download | kafka-python-cda2e17cd115f76f4992a34bab2b684ed08d4fef.tar.gz | |
Rename Cluster -> ClusterMetadata; align with upstream Metadata class
Diffstat (limited to 'kafka/common.py')
| -rw-r--r-- | kafka/common.py | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/kafka/common.py b/kafka/common.py index 173fc82..9615981 100644 --- a/kafka/common.py +++ b/kafka/common.py @@ -425,6 +425,10 @@ def _iter_broker_errors(): kafka_errors = dict([(x.errno, x) for x in _iter_broker_errors()]) +def for_code(error_code): + return kafka_errors.get(error_code, UnknownError) + + def check_error(response): if isinstance(response, Exception): raise response |