delta/python-packages/kafka-python.git/kafka, branch fix_close_socket_attribute_error github.com: mumrah/kafka-python.git Fix possible AttribueError during conn._close_socket 2019-04-02T03:14:44+00:00 Dana Powers dana.powers@gmail.com 2019-04-02T03:14:44+00:00 1f4feee0188768a54eb348ca7d9f374cc5d1bd51 






Dont treat popped conn.close() as failure in state change callback (#1773)
2019-04-02T02:38:48+00:00

Dana Powers
dana.powers@gmail.com

2019-04-02T02:38:48+00:00

51313d792a24059d003f5647ec531cfd9d62d7ab












Avoid race condition on client._conns in send() (#1772)
2019-04-01T02:22:19+00:00

Dana Powers
dana.powers@gmail.com

2019-04-01T02:22:19+00:00

c02df4bcc6ee6920db1be259f44a8f958bb36791

There was a very small possibility that between checking `self._can_send_request(node_id)` and grabbing the connection object via `self._conns[node_id]` that the connection could get closed / recycled / removed from _conns and cause a KeyError. This PR should prevent such a KeyError. In the case where the connection is disconnected by the time we call send(), we should expect conn.send() simply to fail the request.




There was a very small possibility that between checking `self._can_send_request(node_id)` and grabbing the connection object via `self._conns[node_id]` that the connection could get closed / recycled / removed from _conns and cause a KeyError. This PR should prevent such a KeyError. In the case where the connection is disconnected by the time we call send(), we should expect conn.send() simply to fail the request.






lock client.check_version (#1771)
2019-04-01T01:38:47+00:00

Dana Powers
dana.powers@gmail.com

2019-04-01T01:38:47+00:00

3664ae85e5a4c47075489e01688897f8cea8b11d












Dont wakeup during maybe_refresh_metadata -- it is only called by poll() (#1769)
2019-03-31T02:29:30+00:00

Dana Powers
dana.powers@gmail.com

2019-03-31T02:29:30+00:00

b1effa24aca3a6bcf2268354caae12ee82d6b36d












Revert 703f0659 / fix 0.8.2 protocol quick detection (#1763)
2019-03-27T14:45:50+00:00

Dana Powers
dana.powers@gmail.com

2019-03-27T14:45:50+00:00

227a94663d6b0ab11c12236085f79b5b6ffd5568












Send pending requests before waiting for responses (#1762)
2019-03-27T14:45:06+00:00

Dana Powers
dana.powers@gmail.com

2019-03-27T14:45:06+00:00

e45b89bd676844fbc2115b56bbe23c250985005a












Dont do client wakeup when sending from sender thread (#1761)
2019-03-24T15:44:46+00:00

Dana Powers
dana.powers@gmail.com

2019-03-24T15:44:46+00:00

d388b48951327955a9a9031a229f02880e2c6f05












Update sasl configuration docstrings
2019-03-24T01:01:18+00:00

Dana Powers
dana.powers@gmail.com

2019-03-24T01:01:18+00:00

ce9c1d2e2b8d85b2f6c3b2a2ebd280246cfea07f












Support SASL OAuthBearer Authentication (#1750)
2019-03-23T01:24:29+00:00

Phong Pham
pt2pham@users.noreply.github.com

2019-03-23T01:24:29+00:00

8e2ed3ebb45f98e71b7c77fdd52472b815bb7ad2