diff --git a/src/main.py b/src/main.py
index b47e1e6..f69d6d9 100644
--- a/src/main.py
+++ b/src/main.py
@@ -194,7 +194,9 @@ async def main():
             batch_size=BATCH_SIZE, batch_queue=batch_queue, report_queue=report_queue
         )
     )
-    asyncio.create_task(insert_batch(batch_queue=batch_queue))
+    asyncio.create_task(
+        insert_batch(batch_queue=batch_queue, error_queue=producer.send_queue)
+    )
 
     while True:
         await asyncio.sleep(60)