diff --git a/lib/protoparser/opentelemetry/firehose/http.go b/lib/protoparser/opentelemetry/firehose/http.go index a222e7279..d17b14a0d 100644 --- a/lib/protoparser/opentelemetry/firehose/http.go +++ b/lib/protoparser/opentelemetry/firehose/http.go @@ -2,6 +2,7 @@ package firehose import ( "fmt" + "html" "net/http" "time" ) @@ -12,11 +13,12 @@ import ( func WriteSuccessResponse(w http.ResponseWriter, r *http.Request) { requestID := r.Header.Get("X-Amz-Firehose-Request-Id") if requestID == "" { - // This isn't a AWS firehose request - just return an empty response in this case. + // This isn't an AWS firehose request - just return an empty response in this case. w.WriteHeader(http.StatusOK) return } + requestID = html.EscapeString(requestID) body := fmt.Sprintf(`{"requestId":%q,"timestamp":%d}`, requestID, time.Now().UnixMilli()) h := w.Header()