LZ4 codec implementation (e.g., from 'lz4' or 'lz4js' package)
Compression provider for use with registerCompressionProvider
import lz4 from 'lz4'
import { createLz4Provider, registerCompressionProvider, CompressionCodec } from '@qualithm/kafka-client'
const lz4Provider = createLz4Provider({
compressSync: (data) => lz4.encode(data),
decompressSync: (data) => lz4.decode(data)
})
registerCompressionProvider(CompressionCodec.LZ4, lz4Provider)
Creates a Kafka-compatible LZ4 compression provider.
Kafka uses the LZ4 frame format (LZ4F), which includes magic number, frame descriptor, and content checksum. This is different from raw LZ4 block compression.