lz4-kafkajs
TypeScript-ready lz4 compression codec for KafkaJS.
Install
With yarn
$ yarn add lz4-kafkajsWith npm
$ npm install lz4-kafkajsUsage
import { CompressionTypes, CompressionCodecs } from "kafkajs";
import LZ4 from "lz4-kafkajs";
CompressionCodecs[CompressionTypes.LZ4] = new LZ4().codec;Options
All options are passed on to the lz4 library.
Example
To configure the decompression and compression:
import LZ4, {
CompressOptions,
DecompressOptions,
LZ4Options,
} from "lz4-kafkajs";
const decompressOptions: DecompressOptions = {
useJS: false,
};
const compressOptions: CompressOptions = {
blockChecksum: false,
blockIndependence: true,
blockMaxSize: 4 << 20,
dict: false,
dictId: 0,
highCompression: false,
streamChecksum: true,
streamSize: false,
};
const options: LZ4Options = {
decompressOptions,
compressOptions,
};
CompressionCodecs[CompressionTypes.LZ4] = new LZ4(options).codec;