Fix kafka Stream instrumentation (#3438)

open-telemetry · Jun 30, 2021 · 00b1b07 · 00b1b07
1 parent 15ed01d
commit 00b1b07
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/...o/opentelemetry/javaagent/instrumentation/kafkastreams/StreamTaskStopInstrumentation.java b/...o/opentelemetry/javaagent/instrumentation/kafkastreams/StreamTaskStopInstrumentation.java
@@ -10,7 +10,6 @@
 import static net.bytebuddy.matcher.ElementMatchers.isMethod;
 import static net.bytebuddy.matcher.ElementMatchers.isPublic;
 import static net.bytebuddy.matcher.ElementMatchers.named;
-import static net.bytebuddy.matcher.ElementMatchers.takesArguments;
 
 import io.opentelemetry.context.Context;
 import io.opentelemetry.javaagent.extension.instrumentation.TypeInstrumentation;
@@ -29,7 +28,7 @@ public ElementMatcher<TypeDescription> typeMatcher() {
   @Override
   public void transform(TypeTransformer transformer) {
     transformer.applyAdviceToMethod(
-        isMethod().and(isPublic()).and(named("process")).and(takesArguments(0)),
+        isMethod().and(isPublic()).and(named("process")),
         StreamTaskStopInstrumentation.class.getName() + "$StopSpanAdvice");
   }