综合练习

这一课你将能做到

1. 独立搭起「API 写 MySQL → 发 OrderCreated → 双 Consumer Group 各自处理」的完整 lab 链路
2. 为通知与审计两条消费链路实现幂等（去重表/唯一索引），并用 CLI 验证 lag 回落
3. 用 README 写清本站边界（生产主路径 MySQL+Redis，Kafka 为实验），并逐项完成验收清单

为什么要学

前面 11 课每个都是零件：概念、安装、生产、消费、Spring、格式、投递、Streams、监控、选型。零件各自能跑 ≠ 系统能跑——真实工作里你交付的从来不是「会用某个 API」，而是一条能演示、能抗重启、能说清边界的链路。

本课做一个结营作业：完整的订单事件实验。做完它，你就有了能写进简历的实战叙述：「我用 Spring Boot + Kafka 搭过订单事件链路，双消费组订阅、去重表幂等、CLI 验证过 lag」——这句话的每个词你都亲手敲过。

不要求接入生产 API；独立 lab 表 + 本地 Kafka 即可，大胆试错。

人话：结营作业——能跑通、能讲清、能写边界，才算入门闭环。

先建立图像

POST /lab/orders
  └─ @Transactional 写 lab_orders（权威）
  └─ afterCommit → KafkaTemplate.send
        Topic: coderoadmap.order-events（3 分区，key=orderId）
             │
     ┌───────┴────────┐
     ▼                ▼
 group notify     group audit
 记通知日志        INSERT lab_audit_log
 （幂等）          （UNIQUE event_id）
     │                │
     └────────┬───────┘
              ▼
 kafka-consumer-groups --describe → 两组 LAG ≈ 0

元素	值
Topic	coderoadmap.order-events
事件	OrderCreated（必做）、OrderPaid（选做）
Key	orderId
消费组	coderoadmap-notify、coderoadmap-audit
权威库	lab 自己的 lab_orders 表（非生产 cf_*）

跟着做

步骤 1：起 Broker 与 Topic

docker compose up -d
docker exec kafka-lab /opt/kafka/bin/kafka-topics.sh --bootstrap-server localhost:9092 --create --topic coderoadmap.order-events --partitions 3 --replication-factor 1
docker exec kafka-lab /opt/kafka/bin/kafka-topics.sh --bootstrap-server localhost:9092 --describe --topic coderoadmap.order-events

应看到 PartitionCount: 3。

步骤 2：建表

-- 订单真相（lab）
CREATE TABLE lab_orders (
  id VARCHAR(64) PRIMARY KEY,
  user_id VARCHAR(64) NOT NULL,
  amount BIGINT NOT NULL,          -- 金额存分，不用浮点（消息格式课的纪律）
  status VARCHAR(32) NOT NULL,
  created_at TIMESTAMP NOT NULL
);

-- 审计投影：event_id 唯一索引 = 幂等闸门
CREATE TABLE lab_audit_log (
  id BIGINT PRIMARY KEY AUTO_INCREMENT,
  event_id VARCHAR(64) NOT NULL UNIQUE,
  order_id VARCHAR(64) NOT NULL,
  payload JSON NOT NULL,
  created_at TIMESTAMP NOT NULL
);

-- 通知侧去重表
CREATE TABLE lab_processed_events (
  event_id VARCHAR(64) PRIMARY KEY,
  processor VARCHAR(32) NOT NULL,
  processed_at TIMESTAMP NOT NULL
);