delta/python-packages/kafka-python.git/test/record, branch threadsafe_pending_responses github.com: mumrah/kafka-python.git Add DefaultRecordBatch implementation aka V2 message format parser/builder. (#1185) 2017-10-24T22:28:35+00:00 Taras Voinarovskyi voyn1991@gmail.com 2017-10-24T22:28:35+00:00 8b05ee8da50b4c7b832676f4e38f9d92a86639cc Added bytecode optimization for varint and append/read_msg functions. Mostly based on avoiding LOAD_GLOBAL calls. 
Added bytecode optimization for varint and append/read_msg functions. Mostly based on avoiding LOAD_GLOBAL calls.
 Fix timestamp not passed to RecordMetadata (#1273) 2017-10-22T07:56:28+00:00 Taras Voinarovskyi voyn1991@gmail.com 2017-10-22T07:56:28+00:00 a345dcd2ca1b0f8934864c512a4a78c65034dd36 * Fix timestamp not being passed to RecordMetadata properly * Add more tests for LegacyBatch * Fix producer test for recordmetadata 
* Fix timestamp not being passed to RecordMetadata properly

* Add more tests for LegacyBatch

* Fix producer test for recordmetadata
Refactor MessageSet and Message into LegacyRecordBatch to later support v2 message format 2017-10-11T15:09:17+00:00 Taras voyn1991@gmail.com 2017-10-09T21:13:16+00:00 fbea5f04bccd28f3aa15a1711548b131504591ac