Skip to content

Commit f8711a2

Browse files
committed
post-review changes
1 parent 244ba1a commit f8711a2

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

instrumentation/kafka/kafka-clients/kafka-clients-0.11/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/kafkaclients/v0_11/metrics/KafkaMetricsConsumerInstrumentation.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -45,7 +45,6 @@ public static class ConstructorMapAdvice {
4545
@Advice.OnMethodEnter(suppress = Throwable.class)
4646
public static Map<String, Object> onEnter(
4747
@Advice.Argument(0) Map<String, Object> originalConfig) {
48-
Map<String, Object> config = originalConfig;
4948

5049
// In versions of spring-kafka prior to 2.5.0.RC1, when the `ProducerPerThread`
5150
// of DefaultKafkaProducerFactory is set to true, the `config` object entering
@@ -63,7 +62,7 @@ public static Map<String, Object> onEnter(
6362
// https://github.com/open-telemetry/opentelemetry-java-instrumentation/issues/12538
6463

6564
// ensure config is a mutable map and avoid concurrency conflicts
66-
config = new HashMap<>(config);
65+
HashMap<String, Object> config = new HashMap<>(originalConfig);
6766
enhanceConfig(config);
6867
return config;
6968
}

0 commit comments

Comments
 (0)