node-red-contrib-kafka-client
Advanced tools
Comparing version
@@ -17,3 +17,5 @@ module.exports = function(RED) { | ||
options.outOfRangeOffset = config.outOfRangeOffset; | ||
options.fetchMinBytes = config.minbytes || 1; | ||
options.fetchMaxBytes = config.maxbytes || 1048576; | ||
node.consumerGroup = new kafka.ConsumerGroup(options, topic); | ||
@@ -30,3 +32,2 @@ | ||
node.error(err); | ||
init(); | ||
} | ||
@@ -33,0 +34,0 @@ |
{ | ||
"name": "node-red-contrib-kafka-client", | ||
"version": "0.0.6", | ||
"version": "0.0.7", | ||
"description": "Node-RED Kafka Consumer and Producer", | ||
@@ -5,0 +5,0 @@ "node-red": { |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
88422
0.07%123
0.82%