code: def test_lz4_incremental():
      for i in range(1000):
          # lz4 max single block size is 4MB
          # make sure we test with multiple-blocks
          b1 = random_string(100).encode("utf-8") * 50000
          b2 = lz4_decode(lz4_encode(b1))
          assert len(b1) == len(b2)
          assert b1 == b2
  
file_path: kafka-python/test/test_codec.py
imports: from __future__ import absolute_import
  import platform
  import struct
  import pytest
  from kafka.vendor.six.moves import range
  from kafka.codec import has_snappy, has_lz4, has_zstd, gzip_encode, gzip_decode, snappy_encode, snappy_decode, lz4_encode, lz4_decode, lz4_encode_old_kafka, lz4_decode_old_kafka, zstd_encode, zstd_decode
  from test.testutil import random_string
label_desc: Use image node_id 8 for calling a global function with example usage: test_lz4_incremental() without return types