Unable to create multiple listeners using same class with KafkaListener annotation at class level

[bdbogjoe]

There is issue in this line, we have to exclude the current bean if has no annotation in methods or in class level, should be something like :

if (annotatedMethods.isEmpty() && ! hasClassLevelListeners) {
          this.nonAnnotatedClasses.add(bean.getClass());
          this.logger.trace(() -> "No @KafkaListener annotations found on bean type: " + bean.getClass());
}

spring-kafka/spring-kafka/src/main/java/org/springframework/kafka/annotation/KafkaListenerAnnotationBeanPostProcessor.java

Line 380 in c6bbba8

if (annotatedMethods.isEmpty()) {

[garyrussell]

Thanks for reporting.

Curious: How did you create an issue with no labels? The New Issue page does not have an option for that.