*** kafka/codec.py.orig Mon Jul 10 22:32:15 2023
--- kafka/codec.py Mon Jul 10 22:29:47 2023
***************
*** 6,12 ****
import struct
from kafka.vendor import six
! from kafka.vendor.six.moves import range
_XERIAL_V1_HEADER = (-126, b'S', b'N', b'A', b'P', b'P', b'Y', 0, 1, 1)
_XERIAL_V1_FORMAT = 'bccccccBii'
--- 6,12 ----
import struct
from kafka.vendor import six
! from kafka.vendor.six import moves
_XERIAL_V1_HEADER = (-126, b'S', b'N', b'A', b'P', b'P', b'Y', 0, 1, 1)
_XERIAL_V1_FORMAT = 'bccccccBii'
***************
*** 160,166 ****
chunker = lambda payload, i, size: memoryview(payload)[i:size+i].tobytes()
for chunk in (chunker(payload, i, xerial_blocksize)
! for i in range(0, len(payload), xerial_blocksize)):
block = snappy.compress(chunk)
block_size = len(block)
--- 160,166 ----
chunker = lambda payload, i, size: memoryview(payload)[i:size+i].tobytes()
for chunk in (chunker(payload, i, xerial_blocksize)
! for i in moves.range(0, len(payload), xerial_blocksize)):
block = snappy.compress(chunk)
block_size = len(block)