From f1cc4a461f6728b578f1476ec899d6022eb2ef9b Mon Sep 17 00:00:00 2001
From: dzink <dzink@users.noreply.github.com>
Date: Tue, 27 Jun 2017 14:21:34 -0400
Subject: [PATCH] Add tlsOptions to Kafka client.

---
 lib/plugins/NodeKafka/Consumer.js | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/lib/plugins/NodeKafka/Consumer.js b/lib/plugins/NodeKafka/Consumer.js
index a1ad44f..a43db0e 100644
--- a/lib/plugins/NodeKafka/Consumer.js
+++ b/lib/plugins/NodeKafka/Consumer.js
@@ -56,7 +56,7 @@ class KafkaConsumer {
     let self = this;
 
     var kafka = require('kafka-node');
-    self.client = new kafka.Client(options.connectionString, options.clientId, options.zkOptions, options.noAckBatchOptions);
+    self.client = new kafka.Client(options.connectionString, options.clientId, options.zkOptions, options.noAckBatchOptions, options.tlsOptions);
     var topics = [
       {topic: self.topic},
     ];