Update BrokerConnection for use with async client

 - use descriptive names for ConnectionStates enum values
 - Change default send_buffer_bytes config to 131072
 - add can_send_more() and max_in_flight_requests_per_connection config
 - add blacked_out() and reconnect_backoff_ms config
 - last_attempt and last_failure are now public attributes
 - raise TooManyInFlightRequests in conn.send() if cant send more

1 files changed, 4 insertions, 0 deletions

diff --git a/kafka/common.py b/kafka/common.py
index 9615981..eb612d7 100644
--- a/kafka/common.py
+++ b/kafka/common.py
@@ -109,6 +109,10 @@ class CorrelationIdError(KafkaError):
     pass
 
 
+class TooManyInFlightRequests(KafkaError):
+    pass
+
+
 class BrokerResponseError(KafkaError):
     errno = None
     message = None