File tree 2 files changed +2
-4
lines changed
src/main/java/org/example/kafkapost/common/annotation/trace
2 files changed +2
-4
lines changed Original file line number Diff line number Diff line change 1
1
package org .example .kafkapost .common .annotation .trace .aop ;
2
2
3
+ import io .opentelemetry .api .GlobalOpenTelemetry ;
3
4
import io .opentelemetry .api .trace .Span ;
4
5
import io .opentelemetry .api .trace .Tracer ;
5
6
import io .opentelemetry .context .Context ;
13
14
import org .example .kafkapost .common .annotation .trace .util .TraceUtil ;
14
15
import org .springframework .kafka .support .Acknowledgment ;
15
16
import org .springframework .stereotype .Component ;
16
- import io .opentelemetry .api .GlobalOpenTelemetry ;
17
17
18
18
@ Slf4j
19
19
@ RequiredArgsConstructor
@@ -46,7 +46,7 @@ public class TraceZeroPayloadKafkaPayload {
46
46
Context extractedContext = traceUtil .extractContextFromRecord (record );
47
47
48
48
// 2. 기존 Trace 기반 새로운 Span 생성
49
- Span span = tracer .spanBuilder ("Content [Kafka-consume] zeroPayload gRPC call" )
49
+ Span span = tracer .spanBuilder ("kafka-post [Kafka-consume] zeroPayload gRPC call" )
50
50
.setParent (extractedContext )
51
51
.startSpan ();
52
52
Original file line number Diff line number Diff line change @@ -39,8 +39,6 @@ public OpenTelemetry openTelemetry() {
39
39
.setPropagators (ContextPropagators .create (W3CTraceContextPropagator .getInstance ()))
40
40
.build ();
41
41
42
- GlobalOpenTelemetry .set (openTelemetrySdk );
43
-
44
42
return openTelemetrySdk ;
45
43
}
46
44
}
You can’t perform that action at this time.
0 commit comments