From 4fb0cd4d6da192473220bdfc73e35506c3eb9c4c Mon Sep 17 00:00:00 2001
From: Alex Layton <alex@layton.in>
Date: Mon, 26 Apr 2021 20:34:43 -0400
Subject: [PATCH] Fix bug in kafka lib

---
 oada/libs/oada-lib-kafka/base.js | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/oada/libs/oada-lib-kafka/base.js b/oada/libs/oada-lib-kafka/base.js
index eae0389b..0feed455 100755
--- a/oada/libs/oada-lib-kafka/base.js
+++ b/oada/libs/oada-lib-kafka/base.js
@@ -93,8 +93,8 @@ class Base extends EventEmitter {
                     await this.consumer.connect();
                     await this.producer.connect();
 
-                    this.consumer.subscribe({ topic: this.consumeTopic });
-                    this.consumer.run({
+                    await this.consumer.subscribe({ topic: this.consumeTopic });
+                    await this.consumer.run({
                         eachMessage: async ({
                             message: { value, ...data },
                         }) => {