diff --git a/src/main/java/org/digma/NamespaceMethodMatchers.java b/src/main/java/org/digma/NamespaceMethodMatchers.java
index 8294862..c120367 100644
--- a/src/main/java/org/digma/NamespaceMethodMatchers.java
+++ b/src/main/java/org/digma/NamespaceMethodMatchers.java
@@ -83,7 +83,8 @@ private static ElementMatcher<? super MethodDescription> methodsFilterByAnnotati
                 "org.springframework.web.bind.annotation.PostMapping",
                 "org.springframework.web.bind.annotation.DeleteMapping",
                 "org.springframework.web.bind.annotation.PutMapping",
-                "org.springframework.web.bind.annotation.PatchMapping"
+                "org.springframework.web.bind.annotation.PatchMapping",
+                "org.springframework.kafka.annotation.KafkaListener"
         )).or(
                 hasSuperMethod(
                         isAnnotatedWith(namedOneOf(
diff --git a/src/main/java/org/digma/NamespaceTypeMatchers.java b/src/main/java/org/digma/NamespaceTypeMatchers.java
index fe51d06..1d8743d 100644
--- a/src/main/java/org/digma/NamespaceTypeMatchers.java
+++ b/src/main/java/org/digma/NamespaceTypeMatchers.java
@@ -88,10 +88,10 @@ private static ElementMatcher<? super TypeDescription> jaxrsTypes() {
     }
 
     private static ElementMatcher<? super TypeDescription> kafkaTypes() {
-        return declaresMethod(isAnnotatedWith(named("org.springframework.kafka.annotation.KafkaListener")))
+        return isAnnotatedWith(named("org.springframework.kafka.annotation.KafkaListener"))
                 .or(
                         extendsClass(
-                                declaresMethod(isAnnotatedWith(named("org.springframework.kafka.annotation.KafkaListener")))));
+                                isAnnotatedWith(named("org.springframework.kafka.annotation.KafkaListener"))));
     }