delta/python-packages/kafka-python.git/kafka/client_async.py, branch sansio github.com: mumrah/kafka-python.git Fix pending completion IndexError bug caused by multiple threads (#1372) 2018-02-08T19:59:54+00:00 Dana Powers dana.powers@gmail.com 2018-02-08T19:59:54+00:00 41aa0342f8bfa6f2ced61be7a8b0f2cd28fbb671 






use absolute imports everywhere (#1362)
2018-02-06T20:10:45+00:00

Kevin Tindall
kevinkjt2000@users.noreply.github.com

2018-02-06T20:10:45+00:00

9ae0e590b5ea93a9c07d71b55b593e0fcc973bc6












Remove assertion with side effect (#1348)
2018-01-23T17:49:18+00:00

Buğra Gedik
bgedik@gmail.com

2018-01-23T17:49:18+00:00

bfa6e2044ad7ecef8ab042d43e2c4d47467d3949












Read all available socket bytes (#1332)
2018-01-11T01:25:33+00:00

Dana Powers
dana.powers@gmail.com

2018-01-11T01:25:33+00:00

a69320b8e3199fa9d7cfa3947a242e699a045c3b

* Recv all available network bytes before parsing
* Add experimental support for configuring socket chunking parameters




* Recv all available network bytes before parsing
* Add experimental support for configuring socket chunking parameters






Improve KafkaConsumer cleanup (#1339)
2018-01-10T23:56:47+00:00

Dana Powers
dana.powers@gmail.com

2018-01-10T23:56:47+00:00

0a7492443c78d4791cfdf3d6384c02f1c7757c7b












KAFKA-3888 Use background thread to process consumer heartbeats (#1266)
2017-12-21T22:46:10+00:00

Dana Powers
dana.powers@gmail.com

2017-12-21T22:46:10+00:00

ad024d1e897dbf16bd629fa63895bd7af4a8d959












use python standard max value (#1303)
2017-12-07T21:59:58+00:00

lukeWx
4403510+lukekingbru@users.noreply.github.com

2017-12-07T21:59:58+00:00

009290ddd5d4616d70bff93f841e773af8b22750












Fixup for PR 1264 -- required to propagate configuration to BrokerConnection
2017-10-22T00:02:21+00:00

Dana Powers
dana.powers@gmail.com

2017-10-22T00:02:21+00:00

4dbf34abce9b4addbb304520e2f692fbaef60ae5












Merge pull request #1258 from dpkp/pending_completions
2017-10-21T12:20:38+00:00

Taras Voinarovskyi
voyn1991@gmail.com

2017-10-21T12:20:38+00:00

146b893e0fbac21150f74a8ba2f17cc64e1714ad

Move callback processing from BrokerConnection to KafkaClient




Move callback processing from BrokerConnection to KafkaClient






Explicitly check for None rather than falsey
2017-10-19T20:25:53+00:00

Jeff Widman
jeff@jeffwidman.com

2017-10-19T03:28:21+00:00

0bd5d2ab5738065df410ec2f9381844b28fe7425

Be pedantic about checking for identity rather than equality to avoid issues like #1237 / 411bc08f214b7afc36f11bde2047096c06467088





Be pedantic about checking for identity rather than equality to avoid issues like #1237 / 411bc08f214b7afc36f11bde2047096c06467088