spring-kafka中的 KafkaListener 注解的使用方式_@kafkalistener 注解的方法怎么写

使用 Spring Kafka 的 KafkaListener 注解可以轻松地将一个方法标记为 Kafka 消息监听器。

1. 首先，在配置文件中添加 Kafka 相关的配置项：

spring:
  kafka:
    bootstrap-servers: localhost:9092
    consumer:
      group-id: my-group
      auto-offset-reset: earliest
1
2
3
4
5
6

2. 然后，向需要监听 Kafka 消息的方法上添加 KafkaListener 注解：

@KafkaListener(topics = "my-topic")
public void handle(String message) {
    System.out.println("Received message: " + message);
}
1
2
3
4

在上面的示例中，handle() 方法将会监听名为 “my-topic” 的 Kafka 主题，并在接收到消息时将消息打印到控制台。

除了基本的使用方式，KafkaListener 注解还支持许多其他功能，例如：

• 处理特定分区或分区范围的消息
• 使用多个 KafkaListener 以处理来自不同主题的消息
• 使用 SpEL 表达式处理消息
• 处理批量消息等

更多详细内容可以参考 Spring Kafka 的官方文档。