feat: modify kafka writer's options

2024-10-25 11:22:45 +09:00 · 2024-10-25 11:22:45 +09:00 · bd2c08aa53
commit bd2c08aa53
parent cbe2bcfe45
1 changed files with 6 additions and 3 deletions
--- a/main.go
+++ b/main.go
@ -187,7 +187,10 @@ func main() {
 		writer := &kafka.Writer{
 			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 {