@KafkaListener 怎么知道引用的是哪个KafkaListenerContainerFactory的bean
时间: 2024-03-21 19:41:19 浏览: 101
Spring @Bean vs @Service注解区别
5星 · 资源好评率100%
当你在使用`@KafkaListener`注解时,可以通过`containerFactory`属性指定使用哪个`KafkaListenerContainerFactory`的Bean。例如:
```java
@KafkaListener(topics = "myTopic", containerFactory = "myKafkaListenerContainerFactory")
public void listen(String message) {
// 处理消息
}
```
在这个例子中,`containerFactory`属性指定了使用名为`myKafkaListenerContainerFactory`的`KafkaListenerContainerFactory`的Bean来创建Kafka消费者容器。如果没有指定`containerFactory`属性,则会使用默认的`KafkaListenerContainerFactory`。
阅读全文