KafkaListener 指定 ConcurrentKafkaListenerContainerFactory
时间: 2024-01-11 16:04:22 浏览: 203
spring-kafka-batch-listener.zip
KafkaListener 注解可以指定使用哪个 ConcurrentKafkaListenerContainerFactory,例如:
```java
@KafkaListener(
topics = "myTopic",
containerFactory = "myCustomKafkaListenerContainerFactory")
public void listen(String message) {
// 处理消息逻辑
}
```
其中,`myCustomKafkaListenerContainerFactory` 是一个由 `ConcurrentKafkaListenerContainerFactory` 实现类创建的实例,用于控制 KafkaListener 的并发处理方式。通过自定义这个工厂类,我们可以配置 KafkaListener 的并发度、消费者组、批量处理等属性。
阅读全文