refactor(oltp): silence RocketMQ client heartbeat logs in subscriber filter
ZhenYi committed
Modified lib/infra/oltp/src/subscriber.rs lib/infra/oltp/src/subscriber.rs +9 −5 View lib/infra/oltp/src/subscriber.rs
@@ -14,11 +14,15 @@
1414 .unwrap_or_else(|| config.log_filter.clone());
1515 // 连接池与查询执行器自身不产出业务日志，慢查询告警也与请求日志重复。
1616 // 默认静默，但配置里显式写了 sqlx 目标时以用户的选择为准，方便临时排查。
17 let spec = if base.contains("sqlx") {
18 base
19 } else {
20 format!("{base},sqlx=off")
21 };
17 let mut spec = base.clone();
18 if !base.contains("sqlx") {
19 spec.push_str(",sqlx=off");
20 }
21 // RocketMQ 客户端每 5s 打印一次定时任务、拉取与路由刷新，属于库内部心跳。
22 // 默认只保留 warn 及以上：路由缺失、连接异常照样可见，周期性噪音不再进日志。
23 if !base.contains("rocketmq") {
24 spec.push_str(",rocketmq_client_rust=warn,rocketmq_transport=warn");
25 }
2226 let filter =
2327 EnvFilter::try_new(&spec).unwrap_or_else(|_| EnvFilter::new(config.log_filter.as_str()));
2428 let tracer = telemetry