File tree 2 files changed +5
-0
lines changed
src/main/java/org/example/kafkapost/common/annotation/trace
2 files changed +5
-0
lines changed Original file line number Diff line number Diff line change 12
12
import org .aspectj .lang .annotation .Around ;
13
13
import org .aspectj .lang .annotation .Aspect ;
14
14
import org .example .kafkapost .common .annotation .trace .util .TraceUtil ;
15
+ import org .springframework .context .annotation .DependsOn ;
15
16
import org .springframework .kafka .support .Acknowledgment ;
16
17
import org .springframework .stereotype .Component ;
17
18
18
19
@ Slf4j
19
20
@ RequiredArgsConstructor
20
21
@ Component
21
22
@ Aspect
23
+ @ DependsOn ("openTelemetry" )
22
24
public class TraceZeroPayloadKafkaPayload {
23
25
private final Tracer tracer = GlobalOpenTelemetry .getTracer ("kafka-consumer" );
24
26
private final TraceUtil traceUtil ;
Original file line number Diff line number Diff line change 13
13
import org .springframework .beans .factory .annotation .Value ;
14
14
import org .springframework .context .annotation .Bean ;
15
15
import org .springframework .context .annotation .Configuration ;
16
+ import org .springframework .core .annotation .Order ;
16
17
17
18
@ Configuration
18
19
public class TracingConfig {
@@ -39,6 +40,8 @@ public OpenTelemetry openTelemetry() {
39
40
.setPropagators (ContextPropagators .create (W3CTraceContextPropagator .getInstance ()))
40
41
.build ();
41
42
43
+ GlobalOpenTelemetry .set (openTelemetrySdk );
44
+
42
45
return openTelemetrySdk ;
43
46
}
44
47
}
You can’t perform that action at this time.
0 commit comments