summaryrefslogtreecommitdiff
path: root/kafka/record
Commit message (Collapse)AuthorAgeFilesLines
* Fix crc32c deprecation warning (#2128)Jeff Widman2020-09-171-1/+1
| | | Fix a deprecation warning in the newest version.
* Add support for `zstd` compression (#2021)Tincu Gabriel2020-09-072-3/+10
|
* Fix slots usage and use more slotsCarson Ip2020-02-054-0/+26
| | | | | Use empty slots for ABC classes, otherwise classes which inherit from them will still have __dict__. Also use __slots__ for more classes.
* Fix typosCarson Ip2019-11-081-1/+1
|
* 1701 use last offset from fetch v4 if available (#1724)Keith So2019-03-131-0/+4
|
* Be explicit with tuples for %s formattingJeff Widman2018-11-181-1/+1
| | | | Fix #1633
* Add temp workaround for upstream pylint bugJeff Widman2018-10-261-1/+3
| | | | Temporarily workaround https://github.com/PyCQA/pylint/issues/2571 so that we can stop pinning `pylint`.
* Update remote urls: snappy, https, etcJeff Widman2018-10-221-2/+2
| | | | | Snappy URL was outdated. Similarly, many of these sites now support https.
* Add codec validators to record parser and builder for all formats (#1447)Taras2018-04-182-6/+34
|
* Fix MemoryRecord bugs re error handling and add test coverage (#1448)Taras2018-04-183-7/+7
|
* Use hardware accelerated CRC32C function if available (#1389)Taras Voinarovskyi2018-02-211-3/+11
| | | | | | * Use hardware accelerated CRC32C function if available * Add doc notice of optional `crc32c` package
* use absolute imports everywhere (#1362)Kevin Tindall2018-02-065-9/+9
|
* Add DefaultRecordBatch implementation aka V2 message format parser/builder. ↵Taras Voinarovskyi2017-10-257-10/+891
| | | | | (#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-222-9/+48
| | | | | | | | * Fix timestamp not being passed to RecordMetadata properly * Add more tests for LegacyBatch * Fix producer test for recordmetadata
* Added minor fixes for PR reviewTaras2017-10-121-1/+1
|
* Remove the check for timestamp None in producer, as it's done in RecordBatch ↵Taras2017-10-121-14/+7
| | | | | | anyway. Minor abc doc fixes.
* Fix snappy compression on PyPyTaras2017-10-121-4/+5
|
* Refactor MessageSet and Message into LegacyRecordBatch to later support v2 ↵Taras2017-10-115-0/+791
message format