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},
     ];