Easy queue on kafka with node.js
import {Kproducer} from '../dist';
var producer = new Kproducer(config.zookeeper_addr);
producer.send('you_topic','helloworld2');
import {Kconsumer} from '../dist';
import config from './config';
var consumer = new Kconsumer(config.zookeeper_addr, [{topic: 'your_topic'}]);
consumer.onMessage = function(message) {
console.log(message);
}
import {Kproducer} from '../dist';
var producer = new Kproducer(config.zookeeper_addr);
producer.kpub('Ti1','foo','well done');
import {Khub} from '../dist';
import config from './config';
class Ti1{
foo(msg){
console.log("Ti1.foo happend"+msg);
}
bar(msg){
console.log("Ti1.bar happend"+msg);
}
}
class Ti2{
foo2(msg){
console.log("Ti2.foo2 happend"+msg);
}
bar(msg){
console.log("Ti2.bar happend"+msg["somekey"]);
}
}
var khub = new Khub(config.zookeeper_addr,{Ti1,Ti2},{only: "Ti2.bar"});
For more example, check out the example folder.
npm start
cd out
node ./ksub.js