delta/python-packages/kafka-python.git/test, branch compacted_offsets

Avoid busy poll during metadata refresh failure with retry_backoff_ms (#733)

2016-06-21T02:17:49+00:00

Use weakref when registering a producer.close atexit to fix normal gc (#728)

2016-06-18T21:51:23+00:00

* Use weakref when registering a producer.close atexit to fix normal gc
* Test that del(producer) terminates async thread

Rearrange connection tests to separate legacy KafkaConnection

2016-06-04T23:49:38+00:00

Fix regression in MessageSet decoding wrt PartialMessages (#716)

2016-06-01T23:49:17+00:00

Fix socket leaks in KafkaClient (#696)

2016-05-23T00:14:43+00:00

* 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

* 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

Add some simple message protocol tests

2016-05-22T16:51:37+00:00

Rename legacy protocol tests

2016-05-22T16:51:37+00:00

Improve consumer group test loop

2016-05-22T16:51:37+00:00