diff --git a/src/sources/http_client/client.rs b/src/sources/http_client/client.rs index 6732a4975aad7..300ef034e48fa 100644 --- a/src/sources/http_client/client.rs +++ b/src/sources/http_client/client.rs @@ -307,8 +307,7 @@ impl http_client::HttpClientContext for HttpClientContext { fn on_response(&mut self, _url: &Uri, _header: &Parts, body: &Bytes) -> Option> { // get the body into a byte array let mut buf = BytesMut::new(); - let body = String::from_utf8_lossy(body); - buf.extend_from_slice(body.as_bytes()); + buf.extend_from_slice(body); let events = self.decode_events(&mut buf);