Include snappy compression (or working example) about kafkajs HOT 6 CLOSED

I moved my gist to an NPM package
https://www.npmjs.com/package/kafkajs-snappy

I'll update the readme later

from kafkajs.

Hi! Resurrecting an old issue. kafkajs-snappy needs a bit of love, and typescript bindings. :)

from kafkajs.

Hi @pimpelsang, I naively assumed that the library would be enough to deal with the snappy decompression, but I learned today about something called frame support, which is used by Kafka. Here is a working example of the snappy codec, I'll add it to the examples folder. Maybe create a kafkajs-snappy package.

https://gist.github.com/tulios/0a6010e51c42560a9ec47c002eb2481a

from kafkajs.

Confirmed your code works. Will you create the package? I can create it as well, but feel like taking credit for your work :)

from kafkajs.

I get TypeError: codec is not a function when I try to use kafkajs-snappy as intended, by the way.

from kafkajs.

@tulios Could we incorporate the code from kafkajs-snappy into this repo?
If you want I can send the PR.

from kafkajs.