spring kafka框架中@KafkaListener 注解解读和使用案例

下面就让我来详细讲解一下Spring Kafka框架中@KafkaListener注解的使用。

1. @KafkaListener注解介绍

@KafkaListener注解是Spring Kafka框架中用于消费Kafka消息的注解，用于标注一个或多个方法，使它们成为Kafka消息监听器。@KafkaListener注解可以用于类和方法上，用于类上时，需要配合使用@KafkaHandler注解，在方法上使用时，需要指定用于监听哪个topic上的消息。

@KafkaListener注解常用参数如下：

• topics：指定监听哪些topic上的消息，可以是一个或多个topic。
• groupId：消费者的组ID。
• containerFactory：指定使用哪个KafkaListenerContainerFactory，用于创建KafkaListenerContainer。
• id：指定KafkaListenerContainer的ID。
• errorHandler：指定当消息处理出现异常时的错误处理器。
• concurrency：指定并发消费者数量。

2. 使用案例1：最简单的@KafkaListener注解示例

首先，我们看一个最简单的@KafkaListener注解的使用案例：

@KafkaListener(topics = "test")
public void listen(String message) {
    System.out.println("Received: " + message);
}

这个案例中，我们定义了一个@KafkaListener注解的方法，它监听了名为test的topic上的消息，并且打印出收到的消息。

3. 使用案例2：使用容器工厂并指定消费者组ID

下面我们来看一个稍微复杂一点的@KafkaListener注解的使用案例：

@Component
public class MyConsumer {

    @KafkaListener(id = "myConsumer", topics = "myTopic", groupId = "myGroup", containerFactory = "kafkaListenerContainerFactory")
    public void listen(MyMessage message) {
        System.out.println("Received message: " + message);
    }

}

在这个案例中，我们定义了一个名为MyConsumer的类，使用@Component注解将其标识为Spring组件。我们使用@KafkaListener注解标注了一个方法，用于监听名为myTopic的topic上的MyMessage类型的消息，同时指定了消费者组ID为myGroup，并使用了名为kafkaListenerContainerFactory的KafkaListenerContainerFactory。由于使用了@Component注解，Spring框架会自动创建一个MyConsumer对象，使之成为一个Kafka消息监听器。

除了上面提到的几个参数外，@KafkaListener注解还有很多其他的参数可供使用，具体使用方法可以参考Spring Kafka官方文档。