docs: function kafkaInNode(config) {
          RED.nodes.createNode(this,config);
  
          var node = this;
  
          var kafka = require('kafka-node');
          var HighLevelConsumer = kafka.HighLevelConsumer;
          var Client = kafka.Client;
          var topics = String(config.topics);
          var clusterZookeeper = config.zkquorum;
          var groupId = config.groupId;
          var debug = (config.debug == "debug");
          var client = new Client(clusterZookeeper);
  
          var topicJSONArry = [];
  
          // check if multiple topics
          if (topics.indexOf(",") > -1){
              var topicArry = topics.split(',');
              if (debug) {
                  console.log(topicArry)
                  console.log(topicArry.length);
              }
  
              for (i = 0; i < topicArry.length; i++) {
                  if (debug) {
                      console.log(topicArry[i]);
                  }
                  topicJSONArry.push({topic: topicArry[i]});
              }
              topics = topicJSONArry;
          }
          else {
              topics = [{topic:topics}];
          }
  
          var options = {
              groupId: groupId,
              autoCommit: config.autoCommit,
              autoCommitMsgCount: 10
          };
  
  
          try {
              var consumer = new HighLevelConsumer(client, topics, options);
              this.log("Consumer created...");
              this.status({fill:"green",shape:"dot",text:"connected to "+clusterZookeeper});
  
              consumer.on('message', function (message) {
                  if (debug) {
                      console.log(message);
                      node.log(message);
                  }
                  var msg = {payload: message};
                  node.send(msg);
              });
  
              
              consumer.on('error', function (err) {
                 console.error(err);
              });
          }
          catch(e){
              node.error(e);
              return;
          }
      }