From 40363e71c9199055fbf2a2c0377217b7c9ccfbda Mon Sep 17 00:00:00 2001
From: Jachen Duschletta <jcduschletta@gmail.com>
Date: Mon, 19 Feb 2024 10:35:07 -0600
Subject: [PATCH] missing "this." (#187)

* missing this.

* version up'd
---
 plugins/outputs/kafkajs/output_kafkajs.js | 2 +-
 plugins/outputs/kafkajs/package.json      | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

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": {