docs: function kafkaNode(config) {
          RED.nodes.createNode(this,config);
          var topic = config.topic;
          var clusterZookeeper = config.zkquorum;
          var debug = (config.debug == "debug");
          var node = this;
          var kafka = require('kafka-node');
          var HighLevelProducer = kafka.HighLevelProducer;
          var Client = kafka.Client;
          var topics = config.topics;
          var client = new Client(clusterZookeeper);
  
          try {
              this.on("input", function(msg) {
                  var payloads = [];
  
                  // check if multiple topics
                  if (topics.indexOf(",") > -1){
                      var topicArry = topics.split(',');
  
                      for (i = 0; i < topicArry.length; i++) {
                          payloads.push({topic: topicArry[i], messages: msg.payload});
                      }
                  }
                  else {
                      payloads = [{topic: topics, messages: msg.payload}];
                  }
  
                  producer.send(payloads, function(err, data){
                      if (err){
                          node.error(err);
                      }
                      node.log("Message Sent: " + data);
                  });
              });
          }
          catch(e) {
              node.error(e);
          }
          var producer = new HighLevelProducer(client);
          this.status({fill:"green",shape:"dot",text:"connected to "+clusterZookeeper});
      }