diff --git a/main.go b/main.go
index 9e4859e..2a1b817 100644
--- a/main.go
+++ b/main.go
@@ -185,9 +185,12 @@ func main() {
 		}
 
 		writer := &kafka.Writer{
-			Addr:     kafka.TCP(strings.Split(KAFKA_BROKERS, ",")...),
-			Topic:    KAFKA_TOPIC,
-			Balancer: &kafka.LeastBytes{},
+			Addr:                   kafka.TCP(strings.Split(KAFKA_BROKERS, ",")...),
+			Topic:                  KAFKA_TOPIC,
+			AllowAutoTopicCreation: true,
+			Balancer:               &kafka.LeastBytes{},
+			BatchTimeout:           10 * time.Millisecond,
+			Async:                  true,
 		}
 
 		app.Post("/api/streams/telemetry", func(c *fiber.Ctx) error {