From 61e8c64b88137e289f233d1812db3f9fc8242172 Mon Sep 17 00:00:00 2001 From: jackshirazi Date: Tue, 13 Jan 2026 15:37:27 +0000 Subject: [PATCH] Update JavaConcurrent.java --- .../java/co/elastic/apm/agent/concurrent/JavaConcurrent.java | 2 ++ 1 file changed, 2 insertions(+) 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"); }