@KafkaListener 方法不适用于 spring @Profile 注释

Question

我有 2 个 @KafkaListener 方法监听同一个提示 TopicA，

但它们也使用不同的@Profile("dev") 和@Profile("prod") 进行注释，

我设置了 spring.profiles.active=dev ，然后向 TopicA 发送消息，这两种方法都可以消费消息。

这是 @KafkaListener 与 @Profile 的已知错误吗？还是我的配置有问题？

Answer 1

这是正确的，因为@KafkaListener 没有提供 bean。 @Profile 只能限制 bean - @Configuration 类中的工厂方法或扫描 @Services: http://docs.spring.io/spring/docs/current/spring-framework-reference/html/beans.html#beans-definition-profiles-java

因此，您需要将这些方法分发到不同的类，并将 @Profile 移动到它们的 bean 定义级别。