qb-kafka

kafka backend and dialect for QB

qb-kafka

A kafka backend and dialect for qb. A single backend must be selected to be used with qb. This backend uses kafka's nature and guarentees to provide a work queue on receiving of messages to be processed. In addition, kafka can be used as the dialect to skip the rpc work queue pushthat is necessary for other dialects (because they do not share backends).

npm install qb qb-kafka --save
var QB = require('qb').backend(require('qb-kafka').backend)
  , qb = new QB(options)
 
qb.speaks(require('qb-kafka').dialect, kafkaDialectOptions)

MIT in LICENSE file