fix

trask · trask · commit d274cc4a7760 · 2025-02-22T10:08:02.000-08:00
diff --git a/instrumentation/kafka/kafka-clients/kafka-clients-0.11/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/kafkaclients/v0_11/metrics/KafkaMetricsInstrumentationModule.java b/instrumentation/kafka/kafka-clients/kafka-clients-0.11/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/kafkaclients/v0_11/metrics/KafkaMetricsInstrumentationModule.java
@@ -31,7 +31,7 @@ public KafkaMetricsInstrumentationModule() {
   public void injectClasses(ClassInjector injector) {
     injector
         .proxyBuilder(
-            "io.opentelemetry.instrumentation.kafka.internal.OpenTelemetryMetricsReporter")
+            "io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal.OpenTelemetryMetricsReporter")
         .inject(InjectionMode.CLASS_ONLY);
   }
 

Original file line number	Diff line number	Diff line change
`@@ -31,7 +31,7 @@ public KafkaMetricsInstrumentationModule() {`
`31`	`31`	`public void injectClasses(ClassInjector injector) {`
`32`	`32`	`injector`
`33`	`33`	`.proxyBuilder(`
`34`		`- "io.opentelemetry.instrumentation.kafka.internal.OpenTelemetryMetricsReporter")`
	`34`	`+ "io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal.OpenTelemetryMetricsReporter")`
`35`	`35`	`.inject(InjectionMode.CLASS_ONLY);`
`36`	`36`	`}`
`37`	`37`