Skip to content

Commit f52a3b4

Browse files
authored
Warn when deprecated kafka property is used (#10354)
1 parent 27c85e2 commit f52a3b4

File tree

1 file changed

+6
-2
lines changed
  • instrumentation/kafka/kafka-clients/kafka-clients-0.11/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/kafkaclients/v0_11/metrics

1 file changed

+6
-2
lines changed

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

+6-2
Original file line numberDiff line numberDiff line change
@@ -8,6 +8,7 @@
88
import io.opentelemetry.api.GlobalOpenTelemetry;
99
import io.opentelemetry.instrumentation.kafka.internal.OpenTelemetryMetricsReporter;
1010
import io.opentelemetry.instrumentation.kafka.internal.OpenTelemetrySupplier;
11+
import io.opentelemetry.javaagent.bootstrap.internal.DeprecatedConfigProperties;
1112
import io.opentelemetry.javaagent.bootstrap.internal.InstrumentationConfig;
1213
import java.util.ArrayList;
1314
import java.util.List;
@@ -17,8 +18,11 @@
1718
public final class KafkaMetricsUtil {
1819
private static final String INSTRUMENTATION_NAME = "io.opentelemetry.kafka-clients-0.11";
1920
private static final boolean METRICS_ENABLED =
20-
InstrumentationConfig.get()
21-
.getBoolean("otel.instrumentation.kafka.metric-reporter.enabled", true);
21+
DeprecatedConfigProperties.getBoolean(
22+
InstrumentationConfig.get(),
23+
"otel.instrumentation.kafka.metric-reporter.enabled",
24+
"otel.instrumentation.kafka-clients-metrics.enabled",
25+
true);
2226

2327
@SuppressWarnings("unchecked")
2428
public static void enhanceConfig(Map<? super String, Object> config) {

0 commit comments

Comments
 (0)