From 3cc74e2388b5193c8dcbcf46ca179eb90ee741a4 Mon Sep 17 00:00:00 2001 From: emplam27 Date: Wed, 12 Feb 2025 13:58:44 +0900 Subject: [PATCH] Add async option in kafka writer --- server/backend/messagebroker/kafka.go | 1 + 1 file changed, 1 insertion(+) diff --git a/server/backend/messagebroker/kafka.go b/server/backend/messagebroker/kafka.go index b284dff79..68ff045b7 100644 --- a/server/backend/messagebroker/kafka.go +++ b/server/backend/messagebroker/kafka.go @@ -35,6 +35,7 @@ func newKafkaBroker(addresses []string, topic string) *KafkaBroker { Addr: kafka.TCP(addresses...), Topic: topic, Balancer: &kafka.LeastBytes{}, + Async: true, }, } }