Skip to content

Commit 2e62ca8

Browse files
authored
Merge pull request #908 from DataDog/mar-kolya/kafka-trace-records
Trace 'records(TopicPartitions)` in kafka consumer
2 parents 637120c + 058c4ec commit 2e62ca8

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

dd-java-agent/instrumentation/kafka-clients-0.11/src/main/java/datadog/trace/instrumentation/kafka_clients/KafkaConsumerInstrumentation.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -52,7 +52,9 @@ public Map<? extends ElementMatcher<? super MethodDescription>, String> transfor
5252
isMethod()
5353
.and(isPublic())
5454
.and(named("records"))
55-
.and(takesArgument(0, String.class))
55+
.and(
56+
takesArgument(0, String.class)
57+
.or(takesArgument(0, named("org.apache.kafka.common.TopicPartition"))))
5658
.and(returns(Iterable.class)),
5759
IterableAdvice.class.getName());
5860
transformers.put(

0 commit comments

Comments
 (0)