卡夫卡消费者如何使用@KafkaListener写监听器
时间: 2023-12-05 14:57:38 浏览: 40
KafkaListener 是一个注解,可以用于监听 Kafka 消息队列中的消息。下面是一个简单的例子,演示如何使用 @KafkaListener 注解创建一个消息监听器:
首先,需要在 Spring Boot 应用程序的 pom.xml 文件中添加以下依赖项:
```
<dependency>
<groupId>org.springframework.kafka</groupId>
<artifactId>spring-kafka</artifactId>
</dependency>
```
然后,在 Spring Boot 应用程序中创建一个监听器类,如下所示:
```
@Component
public class KafkaConsumer {
@KafkaListener(topics = "myTopic", groupId = "myGroup")
public void listen(String message) {
System.out.println("Received Messasge in group foo: " + message);
}
}
```
在上面的代码中,@KafkaListener 注解用于指定要监听的主题和消费者组。当 Kafka 中有新消息时,被注解的 listen 方法将自动被调用。
最后,在应用程序的配置文件中,需要设置 Kafka 的连接信息,如下所示:
```
spring.kafka.bootstrap-servers=localhost:9092
```
这里的 localhost:9092 是 Kafka 服务器的地址和端口号。如果 Kafka 服务器在另一台机器上,请将 localhost 替换为服务器的 IP 地址或主机名。
这样,就可以使用 @KafkaListener 注解创建 Kafka 消息监听器了。