VIP20
本课程属于：040-后端可观测性事务边界落地 Web后端与企业应用开发 · 共 20 门相关课程，组合学习更完整。
查看所属VIP全部课程 →
← 返回所属目录 咨询 / 购买

错误处理事务边界与Kafka消息链路集成设计

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
课程导论
为什么需要错误处理与事务边界？Kaf…
课程导论Kaf
02
Kafka基础回顾
Topic · Partition · Producer
Kafka基础回顾
03
消息可靠性语义
At-most-once · At-least-once · Exactly-once 定义与对比
消息可靠性语义At-most-once
04
Producer端错误类型
网络异常 · Leader选举 · 超时
Producer端错误类型
05
Producer重试机制
retries · retry.backoff.ms · delivery.timeout.m…
Producer重试机制
06
幂等性Producer
enable.idempotence… · 序列号与Producer ID (P…
Producer幂等性
07
事务性Producer
transactional.id · initTransactions · beginTransaction
Producer事务性
08
事务边界定义
本地数据库事务与Kafka事务的边界…
事务边界定义Kafka
09
经典模式一
本地事务 + 发件箱模式（Outbo…
经典模式一Outbo
10
经典模式二
Saga模式 + Kafka事件驱动…
经典模式二Saga
11
Consumer端错误类型
反序列化错误 · Offset提交失败 · Rebalance
Consumer端错误类型
12
Consumer位移管理
自动提交 vs 手动提交 · 同步提交 vs 异步提交
Consumer位移管理
13
Consumer重试与死信队列（DLQ）
重试Topic设计 · 重试次数 · 死信处理策略
ConsumerDLQ
14
Exactly-Once Semantics (EOS) 在Consumer端
Transactional Data…
Exactly-OnceSemantics
15
Kafka Streams中的错误处理
Processor API异常 · try-catch与punctuat…
KafkaStreams
16
Kafka Connect错误处理
Sink Connector重试 · Dead Letter Queue配…
KafkaConnect
17
消息链路追踪
使用OpenTelemetry或Sp…
消息链路追踪OpenTelemetr…
18
链路上下文传递
Headers中传递TraceId · SpanId · Baggage
链路上下文传递Headers
19
跨服务事务边界
Choreography-based…
跨服务事务边界Choreography…
20
分布式事务协调器
Kafka作为事件总线实现两阶段消息…
分布式事务协调器Kafka
21
幂等性接收端设计
去重表 · 唯一键约束 · 幂等性检查中间件
幂等性接收端设计去重表
22
补偿事务设计
逆向操作 · 补偿消息格式 · 幂等补偿
补偿事务设计逆向操作
23
监控与告警
Kafka指标（JMX） · Consumer Lag · 错误率
监控告警
24
测试策略
单元测试 · 集成测试（Embedded Kafk… · 故障注入测试
测试策略单元测试
25
性能调优
事务超时时间 · 缓冲区大小 · 批量大小对事务性能的影响
性能调优事务超时时间
26
安全与事务
ACL对事务的影响 · TLS加密下的事务性能
安全事务
27
实战案例一
订单系统 - 创建订单 + 发件箱…
实战案例一订单系统
28
实战案例二
库存系统 - Saga模式 + 库存…
实战案例二Saga
29
实战案例三
数据同步 - Kafka Conne…
实战案例三Kafka
30
课程总结
最佳实践 · 常见陷阱 · 未来趋势（KIP-890等）
课程总结最佳实践