Wait for producer to be ready before send

OADA · Jul 23, 2021 · c17851d · c17851d
1 parent fd9317a
commit c17851d
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/oada/libs/oada-lib-kafka/src/base.ts b/oada/libs/oada-lib-kafka/src/base.ts
@@ -213,6 +213,9 @@ export class Base extends EventEmitter {
     topic?: string;
     part: number | null;
   }) {
+    // Wait for producer to be ready?
+    await this.ready
+
     // Assume all messages are JSON
     const value = JSON.stringify({
       time: Date.now(),