core.Consumer

This is a class to wrap ConsumerGroup from kafka-node

Consumer

class Consumer extends EventEmitter {
  constructor(topics, options){
    super();
    // logic
  }

  parse(message){
  }
}

to over write parser :

  core.Consumer.prototype.parse = function(message){
   // new logic
   // to emit to consumer do : this.emit('message', message);
  };