TypeScript-ready lz4 compression codec for KafkaJS.
ℹ️ Requires Node v20 or above to work.
$ yarn add @2l/kafkajs-lz4
import { CompressionTypes, CompressionCodecs } from 'kafkajs';
import LZ4Codec from '@2l/kafkajs-lz4';
CompressionCodecs[CompressionTypes.LZ4] = new LZ4Codec().codec;
$ yarn install
$ yarn test
Thanks to the original author: indix for the initial implementation.
MIT