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.