Function zstd_decode

kafka/codec.py:321–325

(payload)

def zstd_decode(payload):
    if not zstd:
        raise NotImplementedError("Zstd codec is not available")
    with zstd.ZstdDecompressor().stream_reader(io.BytesIO(payload), read_across_frames=True) as reader:
        return reader.read()