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

Comparing version 0.3.1 to 0.3.2

kafkaManager/kafkaConsumerGroup.js

@@ -6,4 +6,2 @@ const nodeName='Kafka Consumer Group';
 
-let kafka;
-
 function sendMsg (node, message) {
@@ -42,3 +40,3 @@ if(logger.active) logger.send({ label: 'sendMsg', node: node.id, message: message })
   }
-  node.consumer = new kafka.ConsumerGroup(node.options, node.topics)
+  node.consumer = new node.kafka.ConsumerGroup(node.options, node.topics)
   node.consumer.on('message', (message) => {
@@ -76,6 +74,6 @@ if(logger.active) logger.send({ label: 'consumer.on.message', node: node.id, message: message })
   node.consumer.on('offsetOutOfRange', function (e) {
-    if(logger.active) logger.send({ label: 'consumer.on.offsetOutOfRange', node: node.id, error: e })
-    node.error('on offsetOutOfRange ' + e)
-    node.status({ fill: 'red', shape: 'ring', text: e.message + ' (PAUSED)' })
-    node.consumer.pause()
+    if(logger.active) logger.send({ label: 'consumer.on.offsetOutOfRange', node: node.id, error: e });
+    node.error('on offsetOutOfRange ' + e);
+    node.status({ fill: 'red', shape: 'ring', text: e.message + ' (PAUSED)' });
+    node.consumer.pause();
   })
@@ -86,3 +84,3 @@ }
     RED.nodes.createNode(this, n)
-    var node = Object.assign(this, n, { connected: false, paused: false, timedout: false })
+    let node = Object.assign(this, n, { connected: false, paused: false, timedout: false })
     node.brokerNode = RED.nodes.getNode(node.broker)
@@ -92,5 +90,3 @@ node.status({ fill: 'yellow', shape: 'ring', text: 'Initialising' })
       if (!node.brokerNode) throw Error('Broker not found ' + node.broker)
-      if (!kafka) {
-        kafka = node.brokerNode.getKafkaDriver()
-      }
+      node.kafka = node.brokerNode.getKafkaDriver()
       node.brokerNode.onStateUp.push({
@@ -161,2 +157,5 @@ node: node,
             break
+          case 'reconnect':
+              connect(node);
+              break
           default:
@@ -163,0 +162,0 @@ throw Error('unknown action: ' + req.params.action)

package.json

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

README.md

@@ -111,2 +111,3 @@ # [node-red-contrib-kafka-manager][2]
 # Version
+0.3.2 fix bug with ssl
 0.3.1 Add hosts list by process.env
@@ -113,0 +114,0 @@ 0.2.14 Add self serve TLS and fix bug plus mask ssl info when debug logging

No alert changes

Improved metrics

Total package byte prevSize

884442

increased by0.02%

Number of lines in readme file

151

increased by0.67%

No dependency changes