diff --git a/src/connectors/kafka.ts b/src/connectors/kafka.ts
index 2ac13b4..35d0fca 100644
--- 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);
                     }
                 },
             })