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

1 files changed, 16 insertions, 0 deletions

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