From 8c64d26100430185f411630e7f75ff7a17bcb614 Mon Sep 17 00:00:00 2001 From: Piotr Wolski Date: Mon, 8 Dec 2025 10:11:49 -0700 Subject: [PATCH] fix Kafka consumer instrumentation --- .../kafka_clients38/KafkaConsumerInfoInstrumentation.java | 1 + .../kafka_clients38/LegacyKafkaConsumerInfoInstrumentation.java | 1 + 2 files changed, 2 insertions(+) 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 index 334aa6c9aac..2df7a897765 100644 --- 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 index 4b415b0bc97..39ff5fafb6c 100644 --- 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", }; }