summaryrefslogtreecommitdiff
path: root/test/record
Commit message (Collapse)AuthorAgeFilesLines
* Fix typosCarson Ip2019-11-081-1/+1
|
* Fix test_legacy_correct_metadata_response on x86 arch (#1718)Stanislav Levin2019-02-211-1/+1
| | | | | | | | | | | | | | | | | | | | | | | | | | The problem is that the type of required operation result is "long". ``` >>> type(278251978 & 0xffffffff) <type 'long'> ``` However, by default "format" method uses __format__(): ``` >>> (278251978 & 0xffffffff).__format__('') '278251978' ``` So, let's compare things using the same engine: ``` >>> "{!r}".format(278251978 & 0xffffffff) '278251978L' ``` Fixes: https://github.com/dpkp/kafka-python/issues/1717 Signed-off-by: Stanislav Levin <slev@altlinux.org>
* Add positive tests for headers in record encode/decodeHeikki Nousiainen2018-09-272-3/+18
|
* Add codec validators to record parser and builder for all formats (#1447)Taras2018-04-182-1/+67
|
* Fix MemoryRecord bugs re error handling and add test coverage (#1448)Taras2018-04-181-1/+68
|
* Use hardware accelerated CRC32C function if available (#1389)Taras Voinarovskyi2018-02-211-2/+3
| | | | | | * Use hardware accelerated CRC32C function if available * Add doc notice of optional `crc32c` package
* Add DefaultRecordBatch implementation aka V2 message format parser/builder. ↵Taras Voinarovskyi2017-10-253-0/+310
| | | | | (#1185) Added bytecode optimization for varint and append/read_msg functions. Mostly based on avoiding LOAD_GLOBAL calls.
* Fix timestamp not passed to RecordMetadata (#1273)Taras Voinarovskyi2017-10-221-6/+87
| | | | | | | | * 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 ↵Taras2017-10-112-0/+193
message format