File tree Expand file tree Collapse file tree 2 files changed +3
-13
lines changed
kafka-clients/kafka-clients-0.11/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/kafkaclients/v0_11/metrics Expand file tree Collapse file tree 2 files changed +3
-13
lines changed Original file line number Diff line number Diff line change 44| -----------------------------------------------------------| ------- | ---------| --------------------------------------------------------------------------------------------------------------------------------|
55| ` otel.instrumentation.kafka.experimental-span-attributes ` | Boolean | ` false ` | Enable the capture of experimental span attributes. |
66| ` otel.instrumentation.kafka.producer-propagation.enabled ` | Boolean | ` true ` | Enable context propagation for kafka message producer. |
7- | ` otel.instrumentation.kafka.metric-reporter.enabled ` | Boolean | ` true ` | Enable kafka consumer and producer metrics. ** Deprecated** , disable instrumentation with name ` kafka-clients-metrics ` instead. |
Original file line number Diff line number Diff line change 99import io .opentelemetry .instrumentation .kafkaclients .common .v0_11 .internal .MetricsReporterList ;
1010import io .opentelemetry .instrumentation .kafkaclients .common .v0_11 .internal .OpenTelemetryMetricsReporter ;
1111import io .opentelemetry .instrumentation .kafkaclients .common .v0_11 .internal .OpenTelemetrySupplier ;
12- import io .opentelemetry .javaagent .bootstrap .internal .AgentInstrumentationConfig ;
13- import io .opentelemetry .javaagent .bootstrap .internal .DeprecatedConfigProperties ;
1412import java .util .List ;
1513import java .util .Map ;
1614import org .apache .kafka .clients .CommonClientConfigs ;
1715
1816public final class KafkaMetricsUtil {
1917 private static final String INSTRUMENTATION_NAME = "io.opentelemetry.kafka-clients-0.11" ;
20- private static final boolean METRICS_ENABLED =
21- DeprecatedConfigProperties .getBoolean (
22- AgentInstrumentationConfig .get (),
23- "otel.instrumentation.kafka.metric-reporter.enabled" ,
24- "otel.instrumentation.kafka-clients-metrics.enabled" ,
25- true );
2618
2719 @ SuppressWarnings ("unchecked" )
2820 public static void enhanceConfig (Map <? super String , Object > config ) {
29- // skip enhancing configuration when metrics are disabled or when we have already enhanced it
30- if (!METRICS_ENABLED
31- || config .get (OpenTelemetryMetricsReporter .CONFIG_KEY_OPENTELEMETRY_INSTRUMENTATION_NAME )
32- != null ) {
21+ // skip enhancing configuration when we have already enhanced it
22+ if (config .get (OpenTelemetryMetricsReporter .CONFIG_KEY_OPENTELEMETRY_INSTRUMENTATION_NAME )
23+ != null ) {
3324 return ;
3425 }
3526 config .merge (
You can’t perform that action at this time.
0 commit comments