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
2 files changed +3
-13
lines changed Original file line number Diff line number Diff line change 4
4
| -----------------------------------------------------------| ------- | ---------| --------------------------------------------------------------------------------------------------------------------------------|
5
5
| ` otel.instrumentation.kafka.experimental-span-attributes ` | Boolean | ` false ` | Enable the capture of experimental span attributes. |
6
6
| ` 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 9
9
import io .opentelemetry .instrumentation .kafkaclients .common .v0_11 .internal .MetricsReporterList ;
10
10
import io .opentelemetry .instrumentation .kafkaclients .common .v0_11 .internal .OpenTelemetryMetricsReporter ;
11
11
import 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 ;
14
12
import java .util .List ;
15
13
import java .util .Map ;
16
14
import org .apache .kafka .clients .CommonClientConfigs ;
17
15
18
16
public final class KafkaMetricsUtil {
19
17
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 );
26
18
27
19
@ SuppressWarnings ("unchecked" )
28
20
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 ) {
33
24
return ;
34
25
}
35
26
config .merge (
You can’t perform that action at this time.
0 commit comments