node-red-contrib-kafka-manager - npm Package Compare versions

Comparing version 0.2.11 to 0.2.12

kafkaManager/kafkaBroker.js

@@ -271,7 +271,2 @@ const nodeName="Kafka Broker";
 
-    if (node.usetls && node.tls) {
-      const tlsNode = RED.nodes.getNode(node.tls)
-      if (tlsNode) tlsNode.addTLSOptions(node.TLSOptions)
-    }
-
     node.getKafkaDriver = () => {
@@ -299,6 +294,20 @@ if (!kafka) {
       }, o)
-      if (node.TLSOptions) {
-        options.sslOptions = node.TLSOptions
+   	  if(logger.active) logger.send({label:'getKafkaClient',usetls:node.usetls,options:options});
+      if(node.usetls) {
+    	  options.sslOptions = {rejectUnauthorized:node.selfSign};
+      	  if(logger.active) logger.send({label:'getKafkaClient tls use',selfSign:node.selfSign});
+    	  try {
+    		  if(!(node.selfServe||node.tls)) throw Error("not self serve or no tls configuration selected");
+    		  if(node.tls) {
+        		  node.tlsNode = RED.nodes.getNode(node.tls);
+     	  	      if (!node.tlsNode) throw Error("tls configuration not found");
+      	  	      Object.assign(options.sslOptions,node.tlsNode.credentials);
+     	      	  if(logger.active) logger.send({label:'getKafkaClient sslOptions',properties:options.sslOptions.keys()});
+    		  }
+    	  } catch(e) {
+    		  node.error("get node tls "+node.tls+" failed, error:"+e);
+    	  }
       }
       if (node.credentials.has_password) {
+    	if(logger.active) logger.send({label:'getKafkaClient node credentials has password, note sasl mechanism is plain'});
         options.sasl = {
@@ -339,3 +348,3 @@ mechanism: 'plain',
     runtimeStop.apply(this)
-  }
+  };
   RED.nodes.registerType('Kafka Broker', KafkaBrokerNode, {
@@ -350,3 +359,3 @@ credentials: {
     }
-  })
+  });
 }

package.json

 {
   "name": "node-red-contrib-kafka-manager",
-  "version": "0.2.11",
+  "version": "0.2.12",
   "description": "Node-RED implements Kafka manager with associand associated .",
@@ -5,0 +5,0 @@ "dependencies": {

README.md

@@ -107,2 +107,3 @@ # [node-red-contrib-kafka-manager][2]
 # Version
+0.2.12 Add self serve TLS and fix bug
 0.2.9 Change debugging mechanism and add kafka-node to dependencies
@@ -109,0 +110,0 @@ 0.2.8 Added all admin api's per Kafka 2.3 but dependent on [kafka-node][4] update.

No alert changes

Improved metrics

Total package byte prevSize

872454

increased by0.19%

Lines of code

1905

increased by0.53%

Number of lines in readme file

145

increased by0.69%

No dependency changes