diff options
| author | Dana Powers <dana.powers@rd.io> | 2015-12-20 10:20:24 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2015-12-28 13:35:35 -0800 |
| commit | 76222f24b21ff10b57b9a355eb0378e68e417169 (patch) | |
| tree | 07a584e405017e488f4dc511b31572b62060a0b7 /kafka/client_async.py | |
| parent | 7c76138640a9ab1390211abc0fb0d5d604c15621 (diff) | |
| download | kafka-python-76222f24b21ff10b57b9a355eb0378e68e417169.tar.gz | |
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
Diffstat (limited to 'kafka/client_async.py')
0 files changed, 0 insertions, 0 deletions