Kafka07-集成-尚硅谷

4-Kafka 集成

4.2 Java 应用场景

4.2.1 Spring Boot 集成

4.2.1.1 创建 Spring Boot 项目

1. 使用 Spring Initializr 或 IDE 新建 Maven 项目，parent 指向 spring-boot-starter-parent 3.0.5，JDK 17。
2. pom.xml 核心依赖：
   • spring-boot-starter-web（排除 logging）
   • spring-kafka
   • kafka-clients 3.6.1
   • 工具：lombok、fastjson、hutool-json、hutool-db
3. resources/application.yml 关键配置：
   • bootstrap-servers: localhost:9092
   • Producer：acks=all、retries=0、batch-size=16384、buffer-memory=33554432
   • Consumer：group-id=test、auto-offset-reset=earliest、enable-auto-commit=true、max-poll-records=2
   • Listener：type=batch、concurrency=2、missing-topics-fatal=true
   • Server：port=9999

4.2.1.2 编写功能代码

1. 配置常量类 SpringBootKafkaConfig：定义 TOPIC_TEST = "test"、GROUP_ID = "test"。
2. 生产者控制器 KafkaProducerController：
   • POST /kafka/produce
   • 接收任意 JSON → JSONUtil.toJsonStr → kafkaTemplate.send
3. 批量消费者 KafkaDataConsumer：
   • @KafkaListener(topics = TOPIC_TEST, groupId = GROUP_ID)
   • 接收 List<String>，逐条解析并打印 "data" 字段

4.2.1.3 集成测试步骤

1. 启动 ZooKeeper
2. 启动 Kafka
3. 启动 Spring Boot 应用（端口 9999）
4. 用 Postman 向 http://localhost:9999/kafka/produce 发 POST 请求，观察控制台消费者输出