chore: fix `opentelemetry-jeager` upgrade

Cargo.lock

@@ -2723,6 +2723,8 @@ dependencies = [
  "pin-project 1.0.8",
  "rand 0.8.4",
  "thiserror",
+ "tokio",
+ "tokio-stream",
 ]
 
 [[package]]
@@ -2737,6 +2739,7 @@ dependencies = [
  "opentelemetry-semantic-conventions",
  "thiserror",
  "thrift",
+ "tokio",
 ]
 
 [[package]]
@@ -4890,7 +4893,7 @@ dependencies = [
  "chrono",
  "futures",
  "observability_deps",
- "opentelemetry 0.15.0",
+ "opentelemetry 0.16.0",
  "opentelemetry-jaeger",
  "snafu",
  "structopt",

trace_exporters/Cargo.toml

@@ -11,8 +11,8 @@ async-trait = "0.1"
 chrono = { version = "0.4" }
 futures = "0.3"
 observability_deps = { path = "../observability_deps" }
-opentelemetry = "0.15"
+opentelemetry = { version = "0.16", features = ["rt-tokio"] }
-opentelemetry-jaeger = { version = "0.15", optional = true }
+opentelemetry-jaeger = { version = "0.15", optional = true, features = ["rt-tokio"] }
 snafu = "0.6"
 structopt = { version = "0.3.21" }
 tokio = { version = "1.0", features = ["macros", "time", "sync", "rt"] }

trace_exporters/src/lib.rs

@@ -119,7 +119,7 @@ fn jaeger_exporter(config: &TracingConfig) -> Result<Arc<dyn TraceCollector>> {
     let exporter = opentelemetry_jaeger::new_pipeline()
         .with_agent_endpoint(agent_endpoint)
         .with_service_name(&config.traces_exporter_jaeger_service_name)
-        .init_exporter()
+        .init_async_exporter(opentelemetry::runtime::Tokio {})
         .map_err(|source| Error::TraceExporter { source })?;
 
     Ok(Arc::new(otel::OtelExporter::new(exporter)))