Fix bug in kafka lib

OADA · Apr 27, 2021 · 4fb0cd4 · 4fb0cd4
1 parent 7805796
commit 4fb0cd4
Showing 1 changed file with 2 additions and 2 deletions.
diff --git 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 },
                         }) => {