Await sending each message

rdf-connect · Oct 21, 2024 · 9258cd8 · 9258cd8
1 parent 5222b85
commit 9258cd8
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/src/connectors/kafka.ts b/src/connectors/kafka.ts
@@ -93,9 +93,7 @@ export const startKafkaStreamReader: ReaderConstructor<KafkaReaderConfig> = (
                 }) {
                     if (topic === config.topic.name) {
                         const element = message.value?.toString() ?? "";
-                        stream.push(element).catch((error) => {
-                            throw error;
-                        });
+                        await stream.push(element);
                     }
                 },
             })