Add async option in kafka writer

yorkie-team · Feb 12, 2025 · 3cc74e2 · 3cc74e2
1 parent dafd831
commit 3cc74e2
Showing 1 changed file with 1 addition and 0 deletions.
diff --git 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,
 		},
 	}
 }