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

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.

npm i kafkajs-snappy-typescript

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

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

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

See LICENSE for more details.