core.Client

Client.connect

function use to create kafka client

Client.connect = function(){
  return new Promise(function(resolve, reject){
    let client = new kafkaNode.KafkaClient(Settings.kafka);

    client.on('ready', ready => { return resolve(client); });
    client.on('error', reject);
  });
};