delta/python-packages/kafka-python.git/kafka/protocol, branch protocol_versions github.com: mumrah/kafka-python.git Use version-indexed lists for request/response protocol structs 2016-04-06T05:54:28+00:00 Dana Powers dana.powers@gmail.com 2016-04-06T05:54:28+00:00 90c729438a2e3f1b194e58231e41bd16bd7b7172 






Update imports from kafka.common -> kafka.errors / kafka.structs
2016-04-05T16:35:45+00:00

Dana Powers
dana.powers@gmail.com

2016-04-05T16:34:48+00:00

5a14bd8c947251d1a8f848175cc3cf2b07af3411












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