delta/python-packages/kafka-python.git/kafka/protocol/message.py, branch lz4 github.com: mumrah/kafka-python.git 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












Support message decompression
2015-12-31T19:19:43+00:00

Dana Powers
dana.powers@rd.io

2015-12-31T19:18:49+00:00

bc2688e69c46fe6890c2e44990720698475c85ed












Add Message.validate_crc() method
2015-12-28T21:45:25+00:00

Dana Powers
dana.powers@rd.io

2015-12-21T09:45:23+00:00

97c7d8829b96f37ae8ee9d3980cc443d77845534












Support pickling of Structs -- _encode_self instance method needs some magic
2015-12-09T23:17:52+00:00

Dana Powers
dana.powers@rd.io

2015-12-09T23:17:52+00:00

9740b2b88b41726f143b3367285dbc118bfa0a8a












Return PartialMessage object in MessageSet.decode if message is truncated by max_bytes
2015-12-09T23:16:37+00:00

Dana Powers
dana.powers@rd.io

2015-12-09T23:16:37+00:00

1636c96df41b61b37883a60238dfb42b353f36a2