delta/python-packages/kafka-python.git/kafka/protocol/message.py, branch subscription_copy

Fixed couple of "leaks" when gc is disabled (#979)

2017-03-07T21:31:46+00:00

PEP-8: Spacing & removed unused imports (#899)

2017-02-09T20:27:16+00:00

Fix message timestamp_type (#828)

2016-09-15T23:29:19+00:00

Always absolute_import

2016-08-03T04:36:00+00:00

Always encode size with MessageSet (#771)

2016-07-17T21:16:27+00:00

Fix regression in MessageSet decoding wrt PartialMessages (#716)

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

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

KAFKA-3025: Message v1 -- add timetamp and use relative offset in compressed messagesets

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

Always pass encoded message bytes to MessageSet.encode()

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

Add support for LZ4 compressed messages using python-lz4 module

2016-01-25T18:09:15+00:00