delta/python-packages/kafka-python.git/test, branch decode_errors github.com: mumrah/kafka-python.git Fix socket leaks in KafkaClient (#696) 2016-05-23T00:14:43+00:00 Dana Powers dana.powers@gmail.com 2016-05-23T00:14:43+00:00 77cb35078a7408ebb0eab4bfc2220cc11c10d3b2 * Cleanup wakeup socketpair on close to avoid leak in KafkaClient * Cleanup unneeded bootstrap connection to avoid leak in KafkaClient * Dont warn on socket disconnections caused by KafkaClient.close() 
* Cleanup wakeup socketpair on close to avoid leak in KafkaClient
* Cleanup unneeded bootstrap connection to avoid leak in KafkaClient
* Dont warn on socket disconnections caused by KafkaClient.close()
 Use standard LZ4 framing for v1 messages / kafka 0.10 (#695) 2016-05-23T00:14:03+00:00 Dana Powers dana.powers@gmail.com 2016-05-23T00:14:03+00:00 1d4251a9efa4c5466ba5095f3ba199bf082a72b5 * LZ4 framing fixed in 0.10 / message v1 -- retain broken lz4 code for compatibility * lz4f does not support easy incremental decompression - raise RuntimeError * Update lz4 codec tests 
* LZ4 framing fixed in 0.10 / message v1 -- retain broken lz4 code for compatibility
* lz4f does not support easy incremental decompression - raise RuntimeError
* Update lz4 codec tests
Use Fetch/Produce API v2 for brokers >= 0.10 (uses message format v1) (#694) 2016-05-22T19:41:17+00:00 Dana Powers dana.powers@gmail.com 2016-05-22T19:41:17+00:00 96530f6a9c4a31d23b069ba162dba6cf45a5efd0 






Add some simple message protocol tests
2016-05-22T16:51:37+00:00

Dana Powers
dana.powers@gmail.com

2016-05-22T07:17:40+00:00

aa5bde6ac382966395f8f1466c46d55cf28c2cce












Rename legacy protocol tests
2016-05-22T16:51:37+00:00

Dana Powers
dana.powers@gmail.com

2016-05-22T06:41:25+00:00

54eb2641ec9aac1249be00dda92c07db39801400












Improve consumer group test loop
2016-05-22T16:51:37+00:00

Dana Powers
dana.powers@gmail.com

2016-05-22T06:30:36+00:00

7719946d74eea6aab6c7865d453d061514096689












* [SimpleConsumer] Fix legacy SimpleConsumer when using compressed messages* [Legacy Protocol] Update legacy protocol to handle compressed messages
2016-05-10T15:34:06+00:00

Paul Cavallaro
paulcavallaro@users.noreply.github.com

2016-05-10T15:34:06+00:00

2c9930dea4a4537cf237ac7cc9db1f3970419b59

* [SimpleConsumer] Fix legacy SimpleConsumer when using compressed messages




* [SimpleConsumer] Fix legacy SimpleConsumer when using compressed messages






Add disconnected socket tests for conn.recv()
2016-04-26T04:45:18+00:00

Dana Powers
dana.powers@gmail.com

2016-04-26T04:45:01+00:00

0b664ff3755e2e21c7aeb76e3f9020afe16ae74b












Rename mocked socket as _socket in test_conn
2016-04-26T04:45:18+00:00

Dana Powers
dana.powers@gmail.com

2016-04-26T04:43:58+00:00

2d759452cf0f0996f23990319466d31581197319












Merge pull request #670 from zackdever/predictable-future
2016-04-25T23:27:37+00:00

Dana Powers
dana.powers@gmail.com

2016-04-25T23:27:37+00:00

22dd002800839fd0788648e8308104bb012d96b7

Consistent error handling in future call/errbacks + better test failures




Consistent error handling in future call/errbacks + better test failures