diff --git a/backend/services/http/handlers_ios.go b/backend/services/http/handlers_ios.go
index 3bc70e9d3..f047c02cf 100644
--- a/backend/services/http/handlers_ios.go
+++ b/backend/services/http/handlers_ios.go
@@ -14,7 +14,7 @@ import (
 	. "openreplay/backend/pkg/messages"
 )
 
-const FILES_SIZE_LIMIT int64 = 1e8		// 100Mb
+const FILES_SIZE_LIMIT int64 = 1e7		// 10Mb
 
 func startSessionHandlerIOS(w http.ResponseWriter, r *http.Request) {
 	type request struct {
diff --git a/backend/services/integrations/main.go b/backend/services/integrations/main.go
index e535dd6cc..f664fe862 100644
--- a/backend/services/integrations/main.go
+++ b/backend/services/integrations/main.go
@@ -19,7 +19,7 @@ import (
 
 func main() {
 	log.SetFlags(log.LstdFlags | log.LUTC | log.Llongfile)
-	TOPIC_RAW := env.String("TOPIC_RAW_WEB")
+	TOPIC_RAW_WEB := env.String("TOPIC_RAW_WEB")
 	POSTGRES_STRING := env.String("POSTGRES_STRING")
 
 	pg := postgres.NewConn(POSTGRES_STRING)
@@ -80,7 +80,7 @@ func main() {
 				sessionID = sessData.ID
 			}
 			// TODO: send to ready-events topic. Otherwise it have to go through the events worker. 
-			producer.Produce(TOPIC_RAW, sessionID, messages.Encode(event.RawErrorEvent))
+			producer.Produce(TOPIC_RAW_WEB, sessionID, messages.Encode(event.RawErrorEvent))
 		case err := <-manager.Errors:
 			log.Printf("Integration error: %v\n", err)
 		case i := <-manager.RequestDataUpdates:
diff --git a/backend/services/sink/main.go b/backend/services/sink/main.go
index 8d3e5ab02..b1bdf8d25 100644
--- a/backend/services/sink/main.go
+++ b/backend/services/sink/main.go
@@ -28,7 +28,7 @@ func main() {
 		env.String("GROUP_SINK"),
 		[]string{ 
 			env.String("TOPIC_RAW_WEB"),
-			env.String("TOPIC_RAW_IOS")
+			env.String("TOPIC_RAW_IOS"),
 	  },
 	  func(sessionID uint64, message Message, _ *types.Meta) {
 	  	//typeID, err := GetMessageTypeID(value)