From 3372d97e1916899d89d841c9e1ec2ca1836a987b Mon Sep 17 00:00:00 2001 From: Trask Stalnaker Date: Mon, 4 May 2026 18:19:38 -0700 Subject: [PATCH] Fix duplicate Pulsar multi-topic receive spans --- .../pulsar/v2_8/ConsumerImplInstrumentation.java | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/instrumentation/pulsar/pulsar-2.8/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/pulsar/v2_8/ConsumerImplInstrumentation.java b/instrumentation/pulsar/pulsar-2.8/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/pulsar/v2_8/ConsumerImplInstrumentation.java index b13bffd050ba..60ecec637aca 100644 --- a/instrumentation/pulsar/pulsar-2.8/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/pulsar/v2_8/ConsumerImplInstrumentation.java +++ b/instrumentation/pulsar/pulsar-2.8/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/pulsar/v2_8/ConsumerImplInstrumentation.java @@ -11,7 +11,6 @@ import static net.bytebuddy.matcher.ElementMatchers.isConstructor; import static net.bytebuddy.matcher.ElementMatchers.isProtected; import static net.bytebuddy.matcher.ElementMatchers.named; -import static net.bytebuddy.matcher.ElementMatchers.namedOneOf; import static net.bytebuddy.matcher.ElementMatchers.takesArgument; import static net.bytebuddy.matcher.ElementMatchers.takesArguments; @@ -34,9 +33,7 @@ class ConsumerImplInstrumentation implements TypeInstrumentation { @Override public ElementMatcher typeMatcher() { - return namedOneOf( - "org.apache.pulsar.client.impl.ConsumerImpl", - "org.apache.pulsar.client.impl.MultiTopicsConsumerImpl"); + return named("org.apache.pulsar.client.impl.ConsumerImpl"); } @Override