VIP20
本课程属于：001-Go Web服务领域边界蓝图 Web后端与企业应用开发 · 共 20 门相关课程，组合学习更完整。
查看所属VIP全部课程 →
← 返回所属目录 咨询 / 购买

Go Web：Kafka流处理与状态存储边界设计

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
课程导论
Kafka在Go Web架构中的角色 · 流处理与状态存储的核心概念 · 课程目标与学习路径
课程导论Kafka
02
Kafka核心概念回顾
Topic · Partition · Producer
Kafka核心概念回顾
03
Go语言Kafka客户端选型
Sarama vs Confluen…
GoKafka
04
基础生产者实现
使用Sarama同步/异步发送消息 · 分区策略 · 重试与幂等性配置
基础生产者实现Sarama
05
基础消费者实现
消费者组 · Rebalance机制 · 手动提交Offset
基础消费者实现消费者组
06
流处理模式概述
At-least-once · Exactly-once · Effectively-once在G…
流处理模式概述At-least-onc…
07
状态存储概念
什么是状态存储 · 有状态vs无状态流处理 · 状态存储的持久化与容错
状态存储概念什么是状态存储
08
Go中内存状态存储
sync.Map · Concurrent Map · 基于RWMutex的自定义状态存储实…
Go内存状态存储
09
基于文件的本地状态存储
使用gob/JSON序列化 · 文件锁 · WAL（Write-Ahead Lo…
基于文件的本地状…gob/JSON
10
基于嵌入式数据库的状态存储
BoltDB · BadgerDB在Kafka流处理中…
基于嵌入式数据库…BoltDB
11
基于外部数据库的状态存储
Redis · PostgreSQL作为状态后端的设…
基于外部数据库的…Redis
12
状态存储边界设计原则
状态分区 · 状态键设计 · TTL与过期策略
状态存储边界设计…状态分区
13
Kafka Streams DSL在Go中的模拟
使用Sarama实现类似Kafka…
KafkaStreams
14
Go流处理框架选型
Watermill · Benthos · Liftbridge的架构与适用场景
Go流处理框架选型
15
基于Watermill的流处理实战
Pub/Sub模式 · 中间件 · Handler链与状态注入
Watermill基于
16
状态存储与流处理的生命周期管理
初始化 · 热加载 · 优雅关闭与状态迁移
状态存储流处理的生命周期…
17
Exactly-Once语义在Go中的挑战
事务性生产者 · 幂等消费者 · 状态存储的事务边界
Exactly-OnceGo
18
状态存储的并发安全
多goroutine读写状态 · 细粒度锁 · 无锁数据结构（如RCU）的应用
状态存储的并发安…goroutine
19
状态存储的监控与指标
Prometheus指标暴露 · 状态大小 · 读写延迟
状态存储的监控指标
20
状态存储的备份与恢复
快照机制 · 增量备份 · 跨数据中心状态同步策略
状态存储的备份恢复
21
Kafka Connect在Go生态中的替代方案
自定义Source/Sink Con…
KafkaConnect
22
事件溯源与CQRS模式
将Kafka作为事件总线 · 状态存储作为读模型 · Go中的实现示例
CQRS事件溯源
23
状态存储的测试策略
单元测试 · 集成测试 · Mock Kafka与Mock状态存…
状态存储的测试策…单元测试
24
性能调优
批量处理 · 压缩 · 缓冲区大小
性能调优批量处理
25
错误处理与重试机制
死信队列 · 重试策略 · 状态回滚与补偿事务
错误处理重试机制
26
安全与权限
Kafka ACL · TLS加密 · 状态存储的加密存储与访问控制
安全权限
27
多租户状态隔离
基于Topic前缀 · 状态命名空间 · 租户级别的资源配额管理
多租户状态隔离Topic
28
实战案例一
实时用户画像系统——使用Kafka流…
实战案例一Kafka
29
实战案例二
订单状态机——使用Kafka事件驱动…
实战案例二Kafka
30
课程总结与未来展望
Kafka流处理与状态存储的演进趋势 · Go生态中的新项目与最佳实践
课程总结未来展望