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












raise ValueError on protocol encode/decode errors
2016-05-22T07:17:51+00:00

Dana Powers
dana.powers@gmail.com

2016-05-22T04:25:55+00:00

f2991be6143c6a1a79815ea20fe95bae8f5376ac












* [SimpleConsumer] Fix legacy SimpleConsumer when using compressed messages* [Legacy Protocol] Update legacy protocol to handle compressed messages
2016-05-10T15:34:06+00:00

Paul Cavallaro
paulcavallaro@users.noreply.github.com

2016-05-10T15:34:06+00:00

2c9930dea4a4537cf237ac7cc9db1f3970419b59

* [SimpleConsumer] Fix legacy SimpleConsumer when using compressed messages




* [SimpleConsumer] Fix legacy SimpleConsumer when using compressed messages






Add protocol support for ApiVersionRequest; identify 0.10 brokers in check_version
2016-05-03T03:59:05+00:00

Dana Powers
dana.powers@gmail.com

2016-05-03T03:59:05+00:00

a3b7dca1b03e8d8d1e1e6c9339a5e12ccb5f51ea












KAFKA-2136: support Fetch and Produce v1 (throttle_time_ms)
2016-04-06T21:48:13+00:00

Dana Powers
dana.powers@gmail.com

2016-04-05T20:04:24+00:00

3d16f2ff5f75380c8a9fce846f35e92bb5bfb935












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