core.Producer

This is a class to wrap HighLevelProducer from kafka-node

Producer

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

  send(data){
   // logic
  }
}

to over write send ( encoder ) :

  core.Producer.prototype.send = function(message){
   // new logic
   // to send to topic do : this.producer.send(payload, callback);
  };