我在同一个主题上有两个@kafkalistener方法,但它们也用不同的@profile(“dev”)和@profile(“prod”)进行注解,我设置spring.profiles.active=dev,并向topica发送消息,这两种方法都可以使用消息。这是一个已知的错误为@kafkalistener与@profile?或者我的配置有问题?
m1m5dgzv1#
没错,因为 @KafkaListener 不呈现豆子。这个 @Profile 只能限制中的bean工厂方法 @Configuration 分类或扫描 @Service 学生:http://docs.spring.io/spring/docs/current/spring-framework-reference/html/beans.html#beans-定义配置文件java所以,您需要的是将这些方法分发到不同的类并移动 @Profile 到他们的bean定义级别。
@KafkaListener
@Profile
@Configuration
@Service
1条答案
按热度按时间m1m5dgzv1#
没错,因为
@KafkaListener
不呈现豆子。这个@Profile
只能限制中的bean工厂方法@Configuration
分类或扫描@Service
学生:http://docs.spring.io/spring/docs/current/spring-framework-reference/html/beans.html#beans-定义配置文件java所以,您需要的是将这些方法分发到不同的类并移动
@Profile
到他们的bean定义级别。