Skip to content

Commit 9813093

Browse files
authored
Merge pull request #912 from DataDog/revert-908-mar-kolya/kafka-trace-records
Revert "Trace 'records(TopicPartitions)` in kafka consumer"
2 parents 1abd507 + b2fc949 commit 9813093

File tree

1 file changed

+1
-3
lines changed

1 file changed

+1
-3
lines changed

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

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

0 commit comments

Comments
 (0)