diff --git a/lib/RequestHandler.go b/lib/RequestHandler.go
index 528b7e5..cc90cb8 100644
--- a/lib/RequestHandler.go
+++ b/lib/RequestHandler.go
@@ -104,7 +104,7 @@ func ClickstreamJsonEventHandler(request RequestObject, topic string) {
 
 func getSource(event map[string]interface{}) string {
 	if event["source"] == nil {
-		event["source"] = "UNKNOWN"
+		return "UNKNOWN"
 	}
 	return event["source"].(string)
 }