This issue got fixed using @kafkajs/zstd instead of zstd-codec
@kafkajs/zstd
zstd-codec
const compressionParams = { level: 1 }; const decompressionParams = {} CompressionCodecs[CompressionTypes.ZSTD] = ZstdCodec(compressionParams, decompressionParams)