return early + increment events dropped when replacement event buffer…

… is full
DataDog · Feb 5, 2025 · 75b6f96 · 75b6f96
1 parent 44da86b
commit 75b6f96
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/lib/saluki-components/src/transforms/aggregate/mod.rs b/lib/saluki-components/src/transforms/aggregate/mod.rs
@@ -479,6 +479,8 @@ impl PassthroughBatcher {
 
             if self.active_buffer.try_push(event).is_some() {
                 error!("Event buffer is full even after forwarding events. Dropping event.");
+                self.telemetry.increment_events_dropped();
+                return;
             }
         }