delta/python-packages/kafka-python.git/kafka/protocol/legacy.py, branch iterator_fetches github.com: mumrah/kafka-python.git Remove KafkaProtocol._decode_message 2015-12-11T02:37:03+00:00 Dana Powers dana.powers@rd.io 2015-12-11T01:48:05+00:00 5cf60f4482852220efa5f727b45617ee3b7ad773 






Convert OffsetCommit and OffsetFetch protocol encode/decode
2015-12-10T19:25:15+00:00

Dana Powers
dana.powers@rd.io

2015-12-10T18:57:27+00:00

7470cade6bb8629d17541e136527369f9d2ec387












Change KafkaProtocol to encode/decode Structs, not bytes
2015-12-09T23:23:20+00:00

Dana Powers
dana.powers@rd.io

2015-12-09T23:20:57+00:00

d0de279459a92e787730f5c85a2cf6f2741cbd97

  - add Payload to kafka.common Request/Responses namedtuples
  - OffsetFetch and OffsetCommit still need to be converted





  - add Payload to kafka.common Request/Responses namedtuples
  - OffsetFetch and OffsetCommit still need to be converted







Switch crc32 back to signed integer -- this is consistent with protocol encoding spec
2015-12-04T19:25:39+00:00

Dana Powers
dana.powers@rd.io

2015-11-28T11:34:37+00:00

f08775a6198cd16a7bc9ec93ffd057f65064ec54












Fix tests broken by legacy module move
2015-12-04T19:25:39+00:00

Dana Powers
dana.powers@rd.io

2015-11-28T11:29:32+00:00

dc94b5fe9f3f93bf6f2235d7f65c62fcf0a2a996












Rename kafka.protocol -> kafka.protocol.legacy
2015-12-04T19:25:39+00:00

Dana Powers
dana.powers@rd.io

2015-11-22T20:01:20+00:00

f0cd6d4082d7abe95693f63b4697cb4ed2b8a6d8