kafka-observe
Advanced tools
Comparing version 1.1.3 to 1.1.4
@@ -18,5 +18,6 @@ const kafka = require("kafka-node"); | ||
idleConnection: options.idleConnection, | ||
}); | ||
this.producer = new ProducerClass(this.client, { | ||
partitionerType: options.partitionerType, | ||
}); | ||
this.producer = new ProducerClass(this.client); | ||
@@ -23,0 +24,0 @@ this.ready = false; |
{ | ||
"name": "kafka-observe", | ||
"version": "1.1.3", | ||
"version": "1.1.4", | ||
"description": "", | ||
@@ -5,0 +5,0 @@ "main": "index.js", |
16224
349