open-telemetry
/
opentelemetry-java-instrumentation
mirror of https://github.com/open-telemetry/opentelemetry-java-instrumentation.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Revert "Trace 'records(TopicPartitions)` in kafka consumer"

This commit is contained in:
Tyler Benson 2019-07-10 17:21:24 -04:00 committed by GitHub
parent a13e4a0229
commit b2fc94950d
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 1 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -52,9 +52,7 @@ public final class KafkaConsumerInstrumentation extends Instrumenter.Default {
isMethod() isMethod()
.and(isPublic()) .and(isPublic())
.and(named("records")) .and(named("records"))
.and( .and(takesArgument(0, String.class))
takesArgument(0, String.class)
.or(takesArgument(0, named("org.apache.kafka.common.TopicPartition"))))
.and(returns(Iterable.class)), .and(returns(Iterable.class)),
IterableAdvice.class.getName()); IterableAdvice.class.getName());
transformers.put( transformers.put(