kafkajs-lz4

TypeScript-ready lz4 compression codec for KafkaJS.

Install

$ yarn install kafkajs-lz4

Usage

import { CompressionTypes, CompressionCodecs } from 'kafkajs';
import LZ4Codec from 'kafkajs-lz4';

CompressionCodecs[CompressionTypes.LZ4] = new LZ4Codec().codec;

Options

All options are transparently passed on to the lz4 library's synchronous encoding options.

Example

To allow encoding Kafka messages of up to 25 MB in size —

const lz4Codec = new LZ4Codec({
    blockMaxSize: 26214400
}).codec;

CompressionCodecs[CompressionTypes.LZ4] = lz4Codec;