@KafkaListener(topics = "bpm.event.businesstechnology", containerFactory = "manualListenerContainerFactory", concurrency = "2")
时间: 2023-12-04 13:03:27 浏览: 111
这段代码是一个 Spring Boot 应用中使用 Kafka 消费者的配置,其中:
- `@KafkaListener` 注解表示这是一个 Kafka 消费者,`topics` 参数指定了订阅的主题名称是 `bpm.event.businesstechnology`。
- `containerFactory` 参数表示使用名为 `manualListenerContainerFactory` 的 Kafka 消费者工厂,该工厂返回一个手动提交的 Kafka 消费者。
- `concurrency` 参数指定了并发消费者的数量,这里是 2 个。
简单来说,这段代码就是在一个 Spring Boot 应用中创建了一个 Kafka 消费者,用于消费 `bpm.event.businesstechnology` 主题的消息。同时,这个消费者是手动提交的,并且有两个并发消费者来处理消息。
阅读全文