*This library is under construction, so there will be bugs and missing features.( Pull requests welcome!
The example below show standard node.js callback-based methods. The library can also be promisified with Bluebird. Take a look at the tests to see what thay may look like.
var client = ;client;var valueSchema =name: 'int'type: 'int';// Produce some messagesclienttopics;// Create a consumerclientconsumers;
A wrapper around the consumer that periodically polls for new records.
var client = ;client;// 500ms poll intervalclientconsumers;