KafkaJS-Snappy

Snappy codec for KafkaJS

Installation

npm install kafkajs-snappy
# yarn add kafkajs-snappy

Configuration

const {  CompressionTypes, CompressionCodecs } = require('kafkajs')
const SnappyCodec = require('kafkajs-snappy')

CompressionCodecs[CompressionTypes.Snappy] = SnappyCodec

License

See LICENSE for more details.