Skip to content

Commit e7d7485

Browse files
committed
fix ci & test
1 parent 7de9292 commit e7d7485

File tree

1 file changed

+8
-2
lines changed

1 file changed

+8
-2
lines changed

instrumentation/spring/spring-boot-autoconfigure/src/main/java/io/opentelemetry/instrumentation/spring/autoconfigure/internal/instrumentation/kafka/KafkaInstrumentationAutoConfiguration.java

Lines changed: 8 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -30,8 +30,14 @@ public class KafkaInstrumentationAutoConfiguration {
3030

3131
@Bean
3232
DefaultKafkaProducerFactoryCustomizer otelKafkaProducerFactoryCustomizer(
33-
OpenTelemetry openTelemetry) {
34-
KafkaTelemetry kafkaTelemetry = KafkaTelemetry.create(openTelemetry);
33+
OpenTelemetry openTelemetry, ObjectProvider<ConfigProperties> configPropertiesProvider) {
34+
KafkaTelemetry kafkaTelemetry =
35+
KafkaTelemetry.builder(openTelemetry)
36+
.setCaptureExperimentalSpanAttributes(
37+
configPropertiesProvider
38+
.getObject()
39+
.getBoolean("otel.instrumentation.kafka.experimental-span-attributes", false))
40+
.build();
3541
return producerFactory -> producerFactory.addPostProcessor(kafkaTelemetry::wrap);
3642
}
3743

0 commit comments

Comments
 (0)