diff options
| author | Taras <voyn1991@gmail.com> | 2017-10-10 00:13:16 +0300 |
|---|---|---|
| committer | Taras <voyn1991@gmail.com> | 2017-10-11 18:09:17 +0300 |
| commit | fbea5f04bccd28f3aa15a1711548b131504591ac (patch) | |
| tree | 1c8a0efe687c2ace72fa146b4f03e15def8e3a95 /kafka/record/util.py | |
| parent | f04435c5ed97fef0975a77a8dc7bae7c284bba63 (diff) | |
| download | kafka-python-fbea5f04bccd28f3aa15a1711548b131504591ac.tar.gz | |
Refactor MessageSet and Message into LegacyRecordBatch to later support v2 message format
Diffstat (limited to 'kafka/record/util.py')
| -rw-r--r-- | kafka/record/util.py | 8 |
1 files changed, 8 insertions, 0 deletions
diff --git a/kafka/record/util.py b/kafka/record/util.py new file mode 100644 index 0000000..098d6f4 --- /dev/null +++ b/kafka/record/util.py @@ -0,0 +1,8 @@ +import binascii + + +def calc_crc32(memview): + """ Calculate simple CRC-32 checksum over a memoryview of data + """ + crc = binascii.crc32(memview) & 0xffffffff + return crc |