chore(internal_logs source): rate limit internal logs (#13154)

vectordotdev · Jun 15, 2022 · b1f7f56 · b1f7f56
1 parent d460af5
commit b1f7f56
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/src/trace.rs b/src/trace.rs
@@ -63,9 +63,12 @@ pub fn init(color: bool, json: bool, levels: &str) {
     let metrics_layer = metrics_layer_enabled()
         .then(|| MetricsLayer::new().with_filter(tracing_subscriber::filter::LevelFilter::INFO));
 
+    let broadcast_layer =
+        RateLimitedLayer::new(BroadcastLayer::new()).with_filter(fmt_filter.clone());
+
     let subscriber = tracing_subscriber::registry()
         .with(metrics_layer)
-        .with(BroadcastLayer::new().with_filter(fmt_filter.clone()));
+        .with(broadcast_layer);
 
     #[cfg(feature = "tokio-console")]
     let subscriber = {