From 948e046b5443e0f38f6062e13153b57d29915a68 Mon Sep 17 00:00:00 2001 From: Viktor Shlapakov Date: Tue, 21 Apr 2015 19:44:27 +0300 Subject: Fix small issues with names/tests --- kafka/common.py | 4 ++++ 1 file changed, 4 insertions(+) (limited to 'kafka/common.py') diff --git a/kafka/common.py b/kafka/common.py index 50f8a77..0e769e4 100644 --- a/kafka/common.py +++ b/kafka/common.py @@ -217,6 +217,10 @@ class KafkaConfigurationError(KafkaError): pass +class AsyncProducerQueueFull(KafkaError): + pass + + def _iter_broker_errors(): for name, obj in inspect.getmembers(sys.modules[__name__]): if inspect.isclass(obj) and issubclass(obj, BrokerResponseError) and obj != BrokerResponseError: -- cgit v1.2.1