@KafkaListener的作用
org.springframework.kafka.annotation.KafkaListener 是 Spring Kafka 库中的一个注解，它用于在 Spring 应用程序中定义 Kafka 消息监听器。这个注解允许你将方法映射为 Kafka 消息的消费者，从而简化了 Kafka 消费者配置和消息处理的代码。
以下是 @KafkaListener 注解的一些关键特性：
- 指定主题：通过注解的
topics或topicPattern属性，你可以指定一个或多个 Kafka 主题，监听器将订阅这些主题。 - 分组管理：通过
groupId属性，你可以指定消费者组的 ID。这是 Kafka 用来管理消息分发的机制。 - 消息处理：使用
@KafkaListener注解的方法将作为消息处理器，当收到消息时，Spring 将调用这个方法。 - 消息偏移量管理：Spring Kafka 提供了自动管理消息偏移量的机制，确保消息被正确地处理和确认。
- 错误处理：可以配置错误处理逻辑，当消息处理方法抛出异常时，可以定义如何记录错误或重试。
- 自定义消费者配置：可以通过
consumerFactory属性指定自定义的消费者工厂，以配置消费者的行为。 - 批量消息处理：可以配置监听器以批处理模式接收消息，提高处理效率。
- 并发控制：通过
concurrency属性，可以控制监听器的并发级别，例如设置每个分区的监听器实例数量。
使用 @KafkaListener 注解可以极大地简化 Kafka 消息消费的实现，使得开发者可以更专注于业务逻辑的实现，而不是底层的消息处理细节。
下面是一个简单的使用示例：
@KafkaListener(topics = "myTopic", groupId = "myGroup")
public void listenAndProcessMessage(String message) {
// 处理接收到的 Kafka 消息
}
在这个例子中，listenAndProcessMessage 方法将作为监听器，订阅 myTopic 主题，并在 myGroup 消费者组中处理接收到的消息。