{"library":"kafka-queue","type":"library","category":null,"description":"Lightweight Kafka wrapper for keyed-message queuing, targeting IoT systems where messages for the same device must be processed in order and by the same consumer. Built on no-kafka (v2.x), it automatically retries connections and supports configurable key fields for partitioning. Version 1.0.4 is the current stable release; development appears to be minimal with no recent updates. Differentiators include a simplified consumer callback that handles commits automatically, and an optional explicit commit pattern.","language":"javascript","status":"active","version":"1.0.4","tags":["javascript"],"last_verified":"Sun Jun 07","install":[{"cmd":"npm install kafka-queue","imports":["const Q = require('kafka-queue')(config);","const Q = require('kafka-queue')(config); Q.producer.connect(...);","const Q = require('kafka-queue')(config); Q.consumer.connect(queueName, groupId, handler);"]},{"cmd":"yarn add kafka-queue","imports":[]},{"cmd":"pnpm add kafka-queue","imports":[]}],"homepage":"https://github.com/peebles/kafka-queue#readme","github":"https://github.com/peebles/kafka-queue","docs":null,"changelog":null,"pypi":null,"npm":"kafka-queue","openapi_spec":null,"status_page":null,"smithery":null,"compatibility":null}