diff --git a/apm-agent-plugins/apm-java-concurrent-plugin/src/main/java/co/elastic/apm/agent/concurrent/JavaConcurrent.java b/apm-agent-plugins/apm-java-concurrent-plugin/src/main/java/co/elastic/apm/agent/concurrent/JavaConcurrent.java index 555ff1b425..f85f8adb8f 100644 --- a/apm-agent-plugins/apm-java-concurrent-plugin/src/main/java/co/elastic/apm/agent/concurrent/JavaConcurrent.java +++ b/apm-agent-plugins/apm-java-concurrent-plugin/src/main/java/co/elastic/apm/agent/concurrent/JavaConcurrent.java @@ -57,6 +57,8 @@ public class JavaConcurrent { EXCLUDED_EXECUTABLE_TYPES.add(CallableLambdaWrapper.class.getName()); // Spring-JMS polling mechanism that translates to passive onMessage handling EXCLUDED_EXECUTABLE_TYPES.add("org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker"); + // Spring-Kafka polling mechanism - active loop that shouldn't inherit context from the starter + EXCLUDED_EXECUTABLE_TYPES.add("org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer"); EXCLUDED_EXECUTABLE_TYPES.add("com.zaxxer.hikari.pool.HikariPool$PoolEntryCreator"); EXCLUDED_EXECUTABLE_TYPES.add("com.github.benmanes.caffeine.cache.BoundedLocalCache.PerformCleanupTask"); }