Function createZstdProvider

createZstdProvider(codec: ZstdCodec): CompressionProvider

Creates a Kafka-compatible ZSTD compression provider.

Kafka uses standard zstd compression format.

Parameters

codec: ZstdCodec
ZSTD codec implementation (e.g., from 'zstd-codec' or '@aspect/zstd' package)

Returns CompressionProvider

Compression provider for use with registerCompressionProvider

Example

import { ZstdCodec } from 'zstd-codec'
import { createZstdProvider, registerCompressionProvider, CompressionCodec } from '@qualithm/kafka-client'

const zstd = await ZstdCodec.run()
const zstdProvider = createZstdProvider({
  compressSync: (data) => zstd.compress(data),
  decompressSync: (data) => zstd.decompress(data)
})
registerCompressionProvider(CompressionCodec.ZSTD, zstdProvider)