diff --git a/clientapi/routing/account_data.go b/clientapi/routing/account_data.go index d6e209dea..5e31a5899 100644 --- a/clientapi/routing/account_data.go +++ b/clientapi/routing/account_data.go @@ -104,6 +104,11 @@ func SaveAccountData( } } + if err := syncProducer.SendData(userID, roomID, dataType); err != nil { + util.GetLogger(req.Context()).WithError(err).Error("syncProducer.SendData failed") + return jsonerror.InternalServerError() + } + dataReq := api.InputAccountDataRequest{ UserID: userID, DataType: dataType,