@KafkaListener方法不带弹簧工作@profile注释

Question

我有2种@KafkaListener方法监听同一tipic TopicA，

但他们也标注了不同的@profile（“开发”）和@profile（ “prod”），

我设置了spring.profiles.active = dev，并发送消息给TopicA，两个方法都可以使用这个消息。

是一个已知的bug的@KafkaListener与@profile？或者我的配置有问题？

Answer 1

这是正确的，因为@KafkaListener不存在的bean。该@Profile可以限制只有豆子 - 工厂方法在@Configuration类或扫描@Service S：http://docs.spring.io/spring/docs/current/spring-framework-reference/html/beans.html#beans-definition-profiles-java

所以，你需要的是状分布的那些方法不同类别和移动@Profile他们的bean定义级别。