fix Kafka consumer instrumentation (#10102)

piochelepiotr · web-flow · commit cf52dcd4cc45 · 2025-12-08T16:04:04.000-05:00
diff --git a/dd-java-agent/instrumentation/kafka/kafka-clients-3.8/src/main/java/datadog/trace/instrumentation/kafka_clients38/KafkaConsumerInfoInstrumentation.java b/dd-java-agent/instrumentation/kafka/kafka-clients-3.8/src/main/java/datadog/trace/instrumentation/kafka_clients38/KafkaConsumerInfoInstrumentation.java
@@ -69,6 +69,7 @@ public String[] helperClassNames() {
     return new String[] {
       packageName + ".KafkaDecorator",
       packageName + ".KafkaConsumerInfo",
+      packageName + ".KafkaConsumerInstrumentationHelper",
       "datadog.trace.instrumentation.kafka_common.ClusterIdHolder",
     };
   }
diff --git a/dd-java-agent/instrumentation/kafka/kafka-clients-3.8/src/main/java/datadog/trace/instrumentation/kafka_clients38/LegacyKafkaConsumerInfoInstrumentation.java b/dd-java-agent/instrumentation/kafka/kafka-clients-3.8/src/main/java/datadog/trace/instrumentation/kafka_clients38/LegacyKafkaConsumerInfoInstrumentation.java
@@ -69,6 +69,7 @@ public String[] helperClassNames() {
     return new String[] {
       packageName + ".KafkaDecorator",
       packageName + ".KafkaConsumerInfo",
+      packageName + ".KafkaConsumerInstrumentationHelper",
       "datadog.trace.instrumentation.kafka_common.ClusterIdHolder",
     };
   }

Original file line number	Diff line number	Diff line change
`@@ -69,6 +69,7 @@ public String[] helperClassNames() {`
`69`	`69`	`return new String[] {`
`70`	`70`	`packageName + ".KafkaDecorator",`
`71`	`71`	`packageName + ".KafkaConsumerInfo",`
	`72`	`+ packageName + ".KafkaConsumerInstrumentationHelper",`
`72`	`73`	`"datadog.trace.instrumentation.kafka_common.ClusterIdHolder",`
`73`	`74`	`};`
`74`	`75`	`}`