kafkajs-snappy-typescript

This little codec allows you to compress and decompress kafka records in snappy for kafkajs.

Motivation

I developped this little package to add strict typing compatibility to Tulio's kafkajs-snappy library (link in the credits section) for people who needs only use typescript.

Installation

npm i kafkajs-snappy-typescript

How to use ?

import { SnappyCodec } from "kafkajs-snappy-typescript";

CompressionCodecs[CompressionTypes.Snappy] = new SnappyCodec().codec;

Credits

Inspired by Tulio's kafkajs-snappy realization and using Brooooooklyn's snappy nodejs compression library for compression and decompression

License

See LICENSE for more details.