1. 课程导论：gRPC与Kafka在微服务中的角色、事务边界与消息链路的核心挑战
1.1 gRPC与Kafka在微服务架构中的定位
现代微服务架构通常采用同步+异步混合通信模式。gRPC与Kafka分别承担了两种截然不同但又互补的通信职责：
| 维度 | gRPC（同步调用） | Kafka（异步消息） |
|---|---|---|
| 通信模式 | 请求-响应（Request-Response） | 发布-订阅（Pub-Sub） |
| 典型场景 | 用户登录、订单查询、支付扣款 | 事件通知、日志采集、数据管道 |
| 一致性要求 | 强一致性（ACID） | 最终一致性（BASE） |
| 延迟特征 | 毫秒级低延迟 | 亚毫秒~秒级吞吐优先 |
| 失败语义 | 超时/重试/熔断 | 至少一次/至多一次/精确一次 |
关键认知：gRPC负责"实时决策"路径，Kafka负责"事件驱动"路径。两者在事务边界处交汇时，会产生分布式系统中最棘手的"双写一致性"问题。
1.2 事务边界与消息链路的核心挑战
当微服务A通过gRPC调用微服务B，同时B需要向Kafka发送消息时，系统面临以下三大核心挑战：
- 分布式事务边界模糊——gRPC调用与Kafka生产操作不在同一个本地事务中，无法使用传统XA协议。
- 消息链路断裂——gRPC调用成功但Kafka发送失败，或Kafka发送成功但gRPC调用回滚，导致上下游数据不一致。
- 参数配置耦合——gRPC的超时、重试、拦截器配置与Kafka的acks、retries、idempotence配置相互影响，调优不当会放大故障。
典型故障场景：订单服务gRPC调用支付服务成功，但支付结果消息未写入Kafka，导致订单状态永久卡在"已支付"而下游库存服务未扣减。反之，消息重复投递导致库存超卖。
1.3 课程目标与学习路径
本课程旨在帮助学员掌握以下核心能力：
- 理解事务边界模型——掌握Saga、TCC、本地消息表、事务消息等模式在gRPC+Kafka场景下的适用边界。
- 掌握参数配置调优——针对gRPC连接池、超时、重试策略与Kafka生产者acks、batch.size、linger.ms、enable.idempotence等参数进行联合调优。
- 构建可观测消息链路——通过OpenTelemetry、Kafka消息头传递traceId，实现端到端链路追踪与故障定位。
- 实战演练——基于真实电商订单场景，完成从理论到代码的完整调优闭环。
学习路径分为四个阶段：
| 阶段 | 章节范围 | 核心产出 |
|---|---|---|
| 基础篇 | 第1~5章 | 理解gRPC与Kafka通信模型、事务边界概念 |
| 配置篇 | 第6~15章 | 掌握gRPC客户端/服务端参数与Kafka生产者/消费者参数调优 |
| 事务篇 | 第16~24章 | 实现Saga、事务消息、本地消息表等模式 |
| 实战篇 | 第25~30章 | 完成全链路压测、故障注入与性能调优报告 |
1.4 gRPC与Kafka交互架构总览
下图展示了典型微服务中gRPC同步调用与Kafka异步消息的混合交互架构：
架构要点：微服务A通过gRPC调用微服务B获取实时响应，同时微服务B将事件写入Kafka供微服务A或其他消费者异步消费。这种混合模式要求开发者同时关注同步调用的超时/重试与异步消息的持久化/顺序保证。
1.5 事务边界问题的本质
事务边界问题的核心在于跨资源协调。gRPC调用涉及网络I/O和远程服务状态变更，Kafka生产涉及磁盘持久化和集群复制。两者无法纳入同一个本地数据库事务中，因此需要引入补偿事务或最终一致性协议。
本课程将重点讲解以下三种主流解决方案：
- 本地消息表——将消息写入本地数据库，通过定时任务扫描发送，配合gRPC回调确认。
- 事务消息（RocketMQ风格）——半消息+本地事务确认，Kafka目前通过事务API实现类似能力。
- Saga模式——将长事务拆分为多个本地事务，通过编排或 choreography 协调补偿操作。