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,
 		},
 	}
 }