delta/python-packages/kafka-python.git/kafka/protocol/message.py, branch 1.2.2 github.com: mumrah/kafka-python.git Fix regression in MessageSet decoding wrt PartialMessages (#716) 2016-06-01T23:49:17+00:00 Dana Powers dana.powers@gmail.com 2016-06-01T23:49:17+00:00 8805d30b781b95786e8f6fc2fa0a24e6e2bd270d 






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







KAFKA-3025: Message v1 -- add timetamp and use relative offset in compressed messagesets
2016-05-22T16:51:37+00:00

Dana Powers
dana.powers@gmail.com

2016-05-22T07:31:16+00:00

795cb9b29fa05d4425f807f54dfa639c125fc0dd












Always pass encoded message bytes to MessageSet.encode()
2016-05-22T07:17:51+00:00

Dana Powers
dana.powers@gmail.com

2016-05-22T04:43:44+00:00

7f4a9361ea168a0e1073801d0b86868de47d1de2












Add support for LZ4 compressed messages using python-lz4 module
2016-01-25T18:09:15+00:00

Dana Powers
dana.powers@rd.io

2016-01-25T06:01:09+00:00

0d5899020a75e22fec14d3e3d7aec8f043d60a31












Support encode and repr on raw BytesIO MessageSets (used in new producer)
2016-01-24T21:26:42+00:00

Dana Powers
dana.powers@rd.io

2016-01-23T23:25:05+00:00

da787214e1d196992aecf269c9d0105e4c934a4d












Add Message and MessageSet HEADER_SIZE bytes
2016-01-24T21:26:42+00:00

Dana Powers
dana.powers@rd.io

2016-01-23T23:19:55+00:00

ee19cbfa4ae92e5fbe41d7ac6e9c199b49c39a88












Message value can be None
2016-01-04T02:46:09+00:00

Dana Powers
dana.powers@rd.io

2016-01-04T02:17:23+00:00

1bcb9f029d7179a23d2e008891cfb9e7f0534d64












Override Message __hash__ to use _encode_self and not recalc crcs
2016-01-04T02:00:03+00:00

Dana Powers
dana.powers@rd.io

2016-01-04T02:00:03+00:00

95e7a65a8eb64bcb589ced003884424f94b58e8f












Assert Message value and (optional) key are bytes
2016-01-04T01:12:15+00:00

Dana Powers
dana.powers@rd.io

2016-01-04T01:12:15+00:00

8f15262c794b16ad330194f062091d0b42ac5a41