springbootkafka消费java实现-CFANZ编程社区

使用 Spring Boot 和 Kafka 实现消息消费的指南

在这篇文章中，我们将开始学习如何使用 Spring Boot 和 Kafka 实现消息的消费。Kafka 是一个分布式流媒体平台，广泛应用于实时数据处理和异步消息传递。接下来，我们将逐步了解整件事情的流程，以及每一步需要实现的代码。

整体流程

以下是实现 Spring Boot Kafka 消费的步骤：

步骤	描述
1	创建 Spring Boot 项目
2	添加 Kafka 依赖
3	配置 Kafka 消费者
4	实现 Kafka 消费消息逻辑
5	运行和测试

步骤详解

1. 创建 Spring Boot 项目

使用 Spring Initializr 创建一个新的 Spring Boot 项目。

访问 [Spring Initializr](
选择项目元信息（如 Group、Artifact 等）。
添加依赖项：Spring Web、Spring for Apache Kafka。
点击 "Generate" 生成并下载项目。

2. 添加 Kafka 依赖

在项目的 pom.xml 文件中，确保有以下 Kafka 依赖：

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

这行代码将 spring-kafka 依赖添加到项目中，使我们能够使用 Kafka 功能。

3. 配置 Kafka 消费者

在 application.properties 中配置 Kafka 消费者属性：

# Kafka 服务器地址
spring.kafka.bootstrap-servers=localhost:9092

# 消费者组 ID
spring.kafka.consumer.group-id=my-group

# 消费者序列化器
spring.kafka.consumer.key-deserializer=org.apache.kafka.common.serialization.StringDeserializer
spring.kafka.consumer.value-deserializer=org.apache.kafka.common.serialization.StringDeserializer

这些属性帮助我们连接 Kafka 服务器，设置消费者组和序列化类型。

4. 实现 Kafka 消费消息逻辑

创建一个 Kafka 消费者类，代码示例如下：

import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Service;

@Service
public class KafkaConsumer {

    @KafkaListener(topics = "my-topic", groupId = "my-group")
    public void listen(ConsumerRecord<String, String> record) {
        // 输出接收到的消息
        System.out.printf("Consumed message: key = %s, value = %s%n", record.key(), record.value());
    }
}

代码说明：

@Service 注解将此类标记为 Spring 的服务组件。
@KafkaListener 注解指明我们关注的 Kafka 主题和消费者组。
listen 方法会自动调用，并接收传入的消息，使用 ConsumerRecord 表示消息记录。

5. 运行和测试

在完成代码编写后，运行 Spring Boot 应用程序。可以使用 Kafka 提供的命令行工具，或使用代码向 "my-topic" 主题发送一些消息。

例如，使用命令行：

kafka-console-producer.sh --broker-list localhost:9092 --topic my-topic --property "parse.key=true" --property "key.separator=:"

输入消息，如 Key1:Hello, Kafka! 后，返回的消息应该在控制台上输出。

旅行图

使用以下 Mermaid 语法描绘实现过程：

journey
    title Spring Boot Kafka 消费流程
    section 创建项目
      创建 Spring Boot 项目: 5: 创建项目
    section 添加依赖
      添加 Kafka 依赖: 5: 了解依赖
    section 配置消费者
      配置 application.properties: 5: 配置 Kafka
    section 实现消费逻辑
      编写 KafkaConsumer 类: 5: 消费消息逻辑
    section 运行和测试
      测试 Kafka 消费: 5: 验证实现