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
