delta/python-packages/kafka-python.git/kafka/protocol, 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












Add __hash__ method to Struct
2016-01-04T01:11:46+00:00

Dana Powers
dana.powers@rd.io

2016-01-04T01:11:46+00:00

d73f26d57fe307897b1a6d000ef971764b7f79ee












Disable pylint errors for py2/py3 compatibility workarounds
2016-01-02T07:00:13+00:00

Dana Powers
dana.powers@rd.io

2016-01-02T06:59:55+00:00

b6e9b7f74dd1f48b5331600fc4c80406c35c6993












Struct __eq__
2016-01-01T20:11:08+00:00

Dana Powers
dana.powers@rd.io

2016-01-01T20:11:08+00:00

9fe904e9bbc64a8bcd1fa5876a76ca93b544cdfe












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

Dana Powers
dana.powers@rd.io

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

bc2688e69c46fe6890c2e44990720698475c85ed