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