synced/tempo
1
0
Fork 0
mirror of https://github.com/grafana/tempo.git synced 2025-03-14 03:06:42 +00:00
Code Issues Packages Projects Releases Wiki Activity

[rhythm] Add baggage propagator to ingest pkg (#4831)

Browse Source
This commit is contained in:
Mario
2025-03-11 12:26:02 +01:00
committed by GitHub
parent 265188db15
commit f40dd6fb82
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
pkg/ingest/writer_client.go
View File

@ -153,7 +153,10 @@ func commonKafkaClientOptions(cfg KafkaConfig, metrics *kprom.Metrics, logger lo
} }
tracer := kotel.NewTracer( tracer := kotel.NewTracer(
kotel.TracerPropagator(propagation.NewCompositeTextMapPropagator(onlySampledTraces{propagation.TraceContext{}})), kotel.TracerPropagator(propagation.NewCompositeTextMapPropagator(
onlySampledTraces{propagation.Baggage{}},
onlySampledTraces{propagation.TraceContext{}},
)),
) )
opts = append(opts, kgo.WithHooks(kotel.NewKotel(kotel.WithTracer(tracer)).Hooks()...)) opts = append(opts, kgo.WithHooks(kotel.NewKotel(kotel.WithTracer(tracer)).Hooks()...))