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

1npm i kafkajs-snappy-typescript

How to use ?

1import { SnappyCodec } from "kafkajs-snappy-typescript";
2
3CompressionCodecs[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.