diff --git a/plugins/outputs/kafkajs/output_kafkajs.js b/plugins/outputs/kafkajs/output_kafkajs.js index 6dc0ae17..63db498f 100644 --- a/plugins/outputs/kafkajs/output_kafkajs.js +++ b/plugins/outputs/kafkajs/output_kafkajs.js @@ -41,7 +41,7 @@ OutputKafka.prototype.start = async function(callback) { } } this.kafka = new Kafka(kconf); - this.producer = kafka.producer() + this.producer = this.kafka.producer() await this.producer.connect() this.producer.on('error', (err) => { diff --git a/plugins/outputs/kafkajs/package.json b/plugins/outputs/kafkajs/package.json index 1c6198bf..f30a6f3f 100644 --- a/plugins/outputs/kafkajs/package.json +++ b/plugins/outputs/kafkajs/package.json @@ -1,6 +1,6 @@ { "name": "@pastash/output_kafkajs", - "version": "1.0.1", + "version": "1.0.2", "description": "kafkajs Output Plugin for @pastash/pastash", "main": "output_kafkajs.js", "scripts": {