diff --git a/rust/otap-dataflow/crates/otap/src/otlp_receiver.rs b/rust/otap-dataflow/crates/otap/src/otlp_receiver.rs index 39c2325a1d..a940d5a7e3 100644 --- a/rust/otap-dataflow/crates/otap/src/otlp_receiver.rs +++ b/rust/otap-dataflow/crates/otap/src/otlp_receiver.rs @@ -483,15 +483,22 @@ impl shared::Receiver for OTLPReceiver { effect_handler: shared::EffectHandler, ) -> Result { let grpc_enabled = self.config.protocols.grpc.is_some(); - let http_enabled = self.config.protocols.http.is_some(); let both_enabled = self.config.protocols.has_both(); - otap_df_telemetry::otel_info!( - "receiver.start", - message = "Starting OTLP Receiver", - grpc_enabled = grpc_enabled, - http_enabled = http_enabled - ); + if let Some(grpc) = &self.config.protocols.grpc { + otap_df_telemetry::otel_info!( + "otlp.receiver.grpc.start", + message = "Starting OTLP gRPC receiver", + endpoint = %grpc.listening_addr + ); + } + if let Some(http) = &self.config.protocols.http { + otap_df_telemetry::otel_info!( + "otlp.receiver.http.start", + message = "Starting OTLP HTTP receiver", + endpoint = %http.listening_addr + ); + } // Determine per-protocol concurrency limits. These are tuned in // `tune_max_concurrent_requests()` to not exceed downstream capacity. diff --git a/rust/otap-dataflow/crates/telemetry/src/registry.rs b/rust/otap-dataflow/crates/telemetry/src/registry.rs index 8e9bdb33b8..8e27a92c87 100644 --- a/rust/otap-dataflow/crates/telemetry/src/registry.rs +++ b/rust/otap-dataflow/crates/telemetry/src/registry.rs @@ -10,7 +10,7 @@ use crate::entity::{EntityRegistry, RegisterOutcome}; use crate::metrics::{ MetricSet, MetricSetHandler, MetricSetRegistry, MetricValue, MetricsIterator, }; -use crate::otel_info; +use crate::otel_debug; use crate::semconv::SemConvRegistry; use parking_lot::Mutex; use slotmap::new_key_type; @@ -76,7 +76,7 @@ impl TelemetryRegistryHandle { // TODO(#1907): This could benefit from logging a human-readable form // of the entity that we refer to later in the logs, instead of logging // every key/value in every line of console_async output. - otel_info!("registry.define_entity", schema, definition); + otel_debug!("registry.define_entity", schema, definition); } outcome.key() }