|
|
KafkaListener 通过 配置文件 订阅 多个 主题 topics
154浏览 · 2023-08-12 14:19:14
是的，[kafka](https://wenku.csdn.net/doc/56k79qpmif?spm=1055.2569.3001.10083)Listener 可以通过配置文件订阅多个主题 [topics](https://wenku.csdn.net/doc/6412b5d9be7fbd1778d449e7?spm=1055.2569.3001.10083)。在 [spring](https://wenku.csdn.net/doc/6412b78ebe7fbd1778d4ab6f?spm=1055.2569.3001.10083) Boot 应用程序中，可以通过在 application.[properties](https://wenku.csdn.net/doc/1vned61yg6?spm=1055.2569.3001.10083) 或 application.yml 文件中配置 spring.kafka.listener.topics 属性来实现。
例如，可以在 application.properties 文件中添加以下配置：
spring.kafka.listener.topics = topic1, topic2, topic3
这样，KafkaListener 将会订阅 topic1、topic2 和 topic3 这三个主题。当然，也可以在代码中使用 @KafkaListener 注解来订阅主题，例如：
```java
@KafkaListener(topics = {"topic1", "topic2", "topic3"})
public void listen(Consumer[record](https://wenku.csdn.net/doc/570d56dtsi?spm=1055.2569.3001.10083)<?, ?> record) {
// 处理消息
这段代码实现了从 topic1、topic2 和 topic3 这三个主题中消费消息的功能。