Skip to content

Commit 4faca8c

Browse files
committed
string
1 parent a1b537d commit 4faca8c

File tree

2 files changed

+15
-15
lines changed

2 files changed

+15
-15
lines changed

instrumentation/kafka/kafka-clients/kafka-clients-2.6/library/src/main/java/io/opentelemetry/instrumentation/kafkaclients/v2_6/TracingConsumerInterceptor.java

Lines changed: 14 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -37,18 +37,20 @@ public class TracingConsumerInterceptor<K, V> implements ConsumerInterceptor<K,
3737

3838
static {
3939
OpenTelemetry openTelemetry = GlobalOpenTelemetry.get();
40-
telemetry = KafkaTelemetry.builder(openTelemetry)
41-
.setMessagingReceiveInstrumentationEnabled(
42-
ConfigPropertiesUtil.getBoolean(
43-
openTelemetry,
44-
false,
45-
"messaging", "experimental", "receive_telemetry", "enabled"))
46-
.setCapturedHeaders(
47-
ConfigPropertiesUtil.getList(
48-
openTelemetry,
49-
emptyList(),
50-
"messaging", "experimental", "capture_headers"))
51-
.build();
40+
telemetry =
41+
KafkaTelemetry.builder(openTelemetry)
42+
.setMessagingReceiveInstrumentationEnabled(
43+
ConfigPropertiesUtil.getBoolean(
44+
openTelemetry,
45+
false,
46+
"messaging",
47+
"experimental",
48+
"receive_telemetry",
49+
"enabled"))
50+
.setCapturedHeaders(
51+
ConfigPropertiesUtil.getList(
52+
openTelemetry, emptyList(), "messaging", "experimental", "capture_headers"))
53+
.build();
5254
}
5355

5456
private String consumerGroup;

instrumentation/log4j/log4j-context-data/log4j-context-data-2.17/library-autoconfigure/src/main/java/io/opentelemetry/instrumentation/log4j/contextdata/v2_17/OpenTelemetryContextDataProvider.java

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -27,9 +27,7 @@
2727
public class OpenTelemetryContextDataProvider implements ContextDataProvider {
2828
private static final boolean BAGGAGE_ENABLED =
2929
ConfigPropertiesUtil.getBoolean(
30-
GlobalOpenTelemetry.get(),
31-
false,
32-
"log4j_context_data", "add_baggage");
30+
GlobalOpenTelemetry.get(), false, "log4j_context_data", "add_baggage");
3331
private static final boolean configuredResourceAttributeAccessible =
3432
isConfiguredResourceAttributeAccessible();
3533
private static final Map<String, String> staticContextData = getStaticContextData();

0 commit comments

Comments
 (0)