diff --git a/changelog.d/22126.fix.md b/changelog.d/22126.fix.md new file mode 100644 index 0000000000000..d9f7e9b451295 --- /dev/null +++ b/changelog.d/22126.fix.md @@ -0,0 +1,3 @@ +Fix `opentelemetry` sink input resolution. The sink is now using the underlying protocol to determine what inputs are accepted. + +authors: pront diff --git a/src/sinks/opentelemetry/mod.rs b/src/sinks/opentelemetry/mod.rs index 4f716d3ff58bf..90d26da27e202 100644 --- a/src/sinks/opentelemetry/mod.rs +++ b/src/sinks/opentelemetry/mod.rs @@ -74,7 +74,9 @@ impl SinkConfig for OpenTelemetryConfig { } fn input(&self) -> Input { - Input::all() + match &self.protocol { + Protocol::Http(config) => config.input(), + } } fn acknowledgements(&self) -> &AcknowledgementsConfig {