From f1ad0247df5bf6e0315ffbb1633d5979da828de0 Mon Sep 17 00:00:00 2001
From: Dana Powers <dana.powers@rd.io>
Date: Thu, 17 Dec 2015 17:29:54 -0800
Subject: Switch BrokerConnection to (mostly) non-blocking IO.  - return
 kafka.Future on send()  - recv is now non-blocking call that completes
 futures when possible  - update KafkaClient to block on future completion

---
 kafka/common.py | 16 ++++++++++++++++
 1 file changed, 16 insertions(+)

(limited to 'kafka/common.py')

diff --git a/kafka/common.py b/kafka/common.py
index 253137c..173fc82 100644
--- a/kafka/common.py
+++ b/kafka/common.py
@@ -93,6 +93,22 @@ class KafkaError(RuntimeError):
     pass
 
 
+class IllegalStateError(KafkaError):
+    pass
+
+
+class RetriableError(KafkaError):
+    pass
+
+
+class DisconnectError(KafkaError):
+    pass
+
+
+class CorrelationIdError(KafkaError):
+    pass
+
+
 class BrokerResponseError(KafkaError):
     errno = None
     message = None
-- 
cgit v1.2.1