# Kafka compression not implemented

**URL:** <https://discourse.nodered.org/t/kafka-compression-not-implemented/65051>\
**Category:** General\
**Created:** [13 July 2022 13:21 UTC](https://discourse.nodered.org/t/kafka-compression-not-implemented/65051 "2022-07-13T13:21:14Z")\
**Posts on this page:** 2\
**Page:** 1

<div class="post-metadata">

**Author:** ![pfe](https://avatars.discourse-cdn.com/v4/letter/p/49beb7/32.png) [@pfe](https://discourse.nodered.org/u/pfe)\
**Post date:** [13 July 2022 13:21 UTC](https://discourse.nodered.org/t/kafka-compression-not-implemented/65051/1 "2022-07-13T13:21:15Z")

</div>

Hello i'm trying to use Kafka flows to consume some datas from a kafka broker. If I publish data and consume the same data , every thing is ok. If I consume a data produced by a another client as node red it makes an error :

{"level":"ERROR","timestamp":"2022-07-13T13:17:20.808Z","logger":"kafkajs","message":"[Consumer] Crash: KafkaJSNotImplemented: Snappy compression not implemented","groupId":"kafka\_js\_b914b054-efaa-443f-9318-168d7ebb65be","stack":"KafkaJSNotImplemented: Snappy compression not implemented\n at 2 (C:\Users\i00204714\.node-red\node\_modules\kafkajs\src\protocol\message\compression\index.js:16:11)\n at lookupCodecByAttributes (C:\Users\i00204714\.node-red\node\_modules\kafkajs\src\protocol\message\compression\index.js:29:18)\n at module.exports (C:\Users\i00204714\.node-red\node\_modules\kafkajs\src\protocol\recordBatch\v0\decoder.js:68:17)\n at decodeMessages (C:\Users\i00204714\.node-red\node\_modules\kafkajs\src\protocol\requests\fetch\v4\decodeMessages.js:27:35)\n at decodePartition (C:\Users\i00204714\.node-red\node\_modules\kafkajs\src\protocol\requests\fetch\v11\response.js:39:19)\n at Decoder.readArrayAsync (C:\Users\i00204714\.node-red\node\_modules\kafkajs\src\protocol\decoder.js:227:24)\n at decodeResponse (C:\Users\i00204714\.node-red\node\_modules\kafkajs\src\protocol\requests\fetch\v11\response.js:44:29)\n at Decoder.readArrayAsync (C:\Users\i00204714\.node-red\node\_modules\kafkajs\src\protocol\decoder.js:227:24)\n at Object.decode (C:\Users\i00204714\.node-red\node\_modules\kafkajs\src\protocol\requests\fetch\v11\response.js:52:35)\n at Connection.send (C:\Users\i00204714\.node-red\node\_modules\kafkajs\src\network\connection.js:325:45)\n at processTicksAndRejections (internal/process/task\_queues.js:97:5)\n at Broker.[private:Broker:sendRequest] (C:\Users\i00204714\.node-red\node\_modules\kafkajs\src\broker\index.js:947:14)\n at Broker.fetch (C:\Users\i00204714\.node-red\node\_modules\kafkajs\src\broker\index.js:368:12)\n at C:\Users\i00204714\.node-red\node\_modules\kafkajs\src\consumer\consumerGroup.js:502:31"}  
{"level":"INFO","timestamp":"2022-07-13T13:17:20.810Z","logger":"kafkajs","message":"[Consumer] Stopped","groupId":"kafka\_js\_b914b054-efaa-443f-9318-168d7ebb65be"}

It seems that the message cannot be de-compressed with Snappy compression ( see not implemented).  
How can I install this Snappy??  
thx you  
Patrick

---

<div class="post-metadata">

**Author:** ![system](https://us1.discourse-cdn.com/flex026/uploads/nodered/original/1X/d073cd938eafa2e558d7c2cd59003b3ef4963033.png) [@system](https://discourse.nodered.org/u/system)\
**Post date:** [11 September 2022 13:21 UTC](https://discourse.nodered.org/t/kafka-compression-not-implemented/65051/2 "2022-09-11T13:21:24Z")

</div>

This topic was automatically closed 60 days after the last reply. New replies are no longer allowed.