*** 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)