Skip to content

Commit b2fc949

Browse files
authored
Revert "Trace 'records(TopicPartitions)` in kafka consumer"
1 parent a13e4a0 commit b2fc949

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)