Skip to content

Commit 90865dd

Browse files
committed
pr review
1 parent b182a71 commit 90865dd

File tree

1 file changed

+6
-7
lines changed
  • instrumentation/kafka/kafka-clients/kafka-clients-2.6/library/src/main/java/io/opentelemetry/instrumentation/kafkaclients/v2_6

1 file changed

+6
-7
lines changed

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

Lines changed: 6 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,6 @@
1919
import io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal.KafkaConsumerContextUtil;
2020
import java.util.Map;
2121
import java.util.Objects;
22-
import java.util.Optional;
2322
import org.apache.kafka.clients.consumer.ConsumerConfig;
2423
import org.apache.kafka.clients.consumer.ConsumerInterceptor;
2524
import org.apache.kafka.clients.consumer.ConsumerRecords;
@@ -54,12 +53,12 @@ public class TracingConsumerInterceptor<K, V> implements ConsumerInterceptor<K,
5453
"otel.instrumentation.messaging.experimental.receive-telemetry.enabled",
5554
false)))
5655
.setCapturedHeaders(
57-
Optional.ofNullable(
58-
messaging.getScalarList("capture_headers/development", String.class))
59-
.orElse(
60-
ConfigPropertiesUtil.getList(
61-
"otel.instrumentation.messaging.experimental.capture-headers",
62-
emptyList())))
56+
messaging.getScalarList(
57+
"capture_headers/development",
58+
String.class,
59+
ConfigPropertiesUtil.getList(
60+
"otel.instrumentation.messaging.experimental.capture-headers",
61+
emptyList())))
6362
.build();
6463
}
6564

0 commit comments

Comments
 (0)