@KafkaListener使用详解

@KafkaListener 是一个非常方便的注解，可以用于将一个方法标记为 Kafka 消息监听器。以下是使用 @KafkaListener 的步骤：

1. 添加依赖：在 pom.xml 文件中添加以下依赖：

<dependency>
  <groupId>org.springframework.kafka</groupId>
  <artifactId>spring-kafka</artifactId>
  <version>2.5.7.RELEASE</version>
</dependency>

2. 配置 Kafka：在 application.properties 文件中配置 Kafka 的相关信息，如下所示：

spring.kafka.bootstrap-servers=localhost:9092
spring.kafka.consumer.group-id=my-group

3. 创建监听器方法：创建一个方法，用于处理从 Kafka 主题中接收到的消息。

@KafkaListener(topics = "my-topic", groupId = "my-group")
public void listen(String message) {
    System.out.println("Received message: " + message);
}

4. 启动应用程序：启动 Spring Boot 应用程序，@KafkaListener 注解将自动注册为 Kafka 消息监听器。

@KafkaListener 注解还支持其他参数，例如指定消息的反序列化器、消息的分区等。更多详细信息可以参考 Spring Kafka 的官方文档。