Emit events as {payload: lz4.decompress(event.payload)}.
{payload: lz4.decompress(event.payload)}
NONE
pipeline: parse-lz4: inputs: []