diff --git a/src/sources/datadog_agent/metrics.rs b/src/sources/datadog_agent/metrics.rs index 0a02e2a11dc95..60be1e7cd2791 100644 --- a/src/sources/datadog_agent/metrics.rs +++ b/src/sources/datadog_agent/metrics.rs @@ -212,7 +212,7 @@ fn decode_datadog_series_v2( return Ok(Vec::new()); } - let metrics = decode_ddseries_v2(body, &api_key, events_received).map_err(|error| { + let metrics = decode_ddseries_v2(body, &api_key).map_err(|error| { ErrorMessage::new( StatusCode::UNPROCESSABLE_ENTITY, format!("Error decoding Datadog sketch: {:?}", error), @@ -230,7 +230,6 @@ fn decode_datadog_series_v2( pub(crate) fn decode_ddseries_v2( frame: Bytes, api_key: &Option>, - events_received: &Registered, ) -> crate::Result> { let payload = MetricPayload::decode(frame)?; let decoded_metrics: Vec = payload @@ -336,11 +335,6 @@ pub(crate) fn decode_ddseries_v2( }) .collect(); - events_received.emit(CountByteSize( - decoded_metrics.len(), - decoded_metrics.estimated_json_encoded_size_of(), - )); - Ok(decoded_metrics) }