springboot实现kafka优雅订阅
时间: 2023-11-20 11:54:10 浏览: 44
为了实现Kafka的优雅订阅,我们可以使用Spring Boot提供的@KafkaListener注解。这个注解可以将一个方法标记为Kafka消息监听器,当有消息到达时,该方法将被自动调用。下面是实现Kafka优雅订阅的步骤:
1.在pom.xml文件中添加Kafka依赖:
```xml
<dependency>
<groupId>org.springframework.kafka</groupId>
<artifactId>spring-kafka</artifactId>
<version>2.5.4.RELEASE</version>
</dependency>
```
2.在application.properties文件中配置Kafka:
```properties
spring.kafka.bootstrap-servers=localhost:9092
spring.kafka.consumer.group-id=my-group
spring.kafka.consumer.auto-offset-reset=earliest
```
3.创建一个Kafka消息监听器:
```java
@Component
public class MyKafkaListener {
@KafkaListener(topics = "my-topic", groupId = "my-group")
public void listen(String message) {
System.out.println("Received message: " + message);
}
}
```
4.启动应用程序并发送一些消息到“my-topic”主题。您应该能够在控制台上看到已接收的消息。