delta/python-packages/kafka-python.git/kafka/conn.py, branch conn_send_buffer

delta/python-packages/kafka-python.git/kafka/conn.py, branch conn_send_buffer github.com: mumrah/kafka-python.git Send socket data via non-blocking IO with send buffer 2019-09-29T06:57:49+00:00 Dana Powers dana.powers@gmail.com 2019-09-29T06:57:49+00:00 f95e7bb6d2a02c3c0cd0f9827b39bfe508ccd638

Rely on socket selector to detect completed connection attempts (#1909) 2019-09-29T02:30:09+00:00 Dana Powers dana.powers@gmail.com 2019-09-29T02:30:09+00:00 89bf6a6ee51e8a54f909eae4785d04e485b91198

Improve connection lock handling; always use context manager (#1895) 2019-09-03T15:47:10+00:00 Dana Powers dana.powers@gmail.com 2019-09-03T15:47:10+00:00 7a69952e956412f45b1eed1e217931e3ec33f2e7

Update conn.py 2019-08-16T18:00:15+00:00 Cameron Boulton cameronboulton@gmail.com 2019-08-15T23:59:08+00:00 ace6af5e5d2ff7b900bc694065562127b4efe8dc

Fix minor typo (#1865) 2019-07-14T15:22:10+00:00 Carson Ip carsonip@users.noreply.github.com 2019-07-14T15:22:10+00:00 eed25fc36110b12ec370b4d0e332173abce9076f

Catch TimeoutError in BrokerConnection send/recv (#1820) 2019-05-30T03:49:32+00:00 Dana Powers dana.powers@gmail.com 2019-05-30T03:49:32+00:00 5bb1abd3495ce81a0522b2a66e6c5d2731dae77b

Do not call state_change_callback with lock (#1775) 2019-04-03T04:27:49+00:00 Dana Powers dana.powers@gmail.com 2019-04-03T04:27:49+00:00 91d31494d02ea636a991abb4dfb25dd904eefd45

Additional BrokerConnection locks to synchronize protocol/IFR state (#1768) 2019-04-02T16:23:44+00:00 Dana Powers dana.powers@gmail.com 2019-04-02T16:23:44+00:00 27cd93be3e7f2e3f3baca04d2126cf3bb6374668

Return connection state explicitly after close in connect() (#1778) 2019-04-02T16:21:01+00:00 Dana Powers dana.powers@gmail.com 2019-04-02T16:21:01+00:00 ed4cab65704fb5c1c5f0c1071590ca0a7b3fbf4e

Reset reconnect backoff on SSL connection (#1777) 2019-04-02T16:20:35+00:00 Dana Powers dana.powers@gmail.com 2019-04-02T16:20:35+00:00 6ca6f367f16cdbf056bc2b49c6b47e43f734c06a