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

Go Web：Kafka分区分配与消费者组边界

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
Kafka基础概念
Topic · Partition · Broker
Kafka基础概念
02
Go语言环境搭建
Go SDK安装 · GOPATH与Go Modules配… · 常用IDE（VS Code/GoLa…
Go语言环境搭建
03
Kafka集群部署
单节点与多节点部署 · Zookeeper/KRaft模式对… · 关键配置参数
Kafka集群部署
04
Go连接Kafka
使用Sarama库初始化Produc… · 配置连接参数
GoKafka
05
分区策略详解
RoundRobin · Range · Sticky
分区策略详解RoundRobin
06
消费者组协调器
GroupCoordinator角色 · GroupCoordinator选举 · Offset管理
消费者组协调器GroupCoordin…
07
再均衡机制
再均衡触发条件 · Eager与Cooperative再… · 再均衡流程
再均衡机制再均衡触发条件
08
分区分配算法实现
Go语言实现RoundRobin分配… · 代码与流程图
分区分配算法实现Go
09
分区分配算法实现
Go语言实现Range分配算法 · 代码与流程图
分区分配算法实现Go
10
分区分配算法实现
Go语言实现Sticky分配算法 · 代码与流程图
分区分配算法实现Go
11
消费者组状态机
Stable · PreparingRebalance · CompletingRebalanc…
消费者组状态机Stable
12
心跳机制
心跳请求与响应 · 会话超时 · 最大轮询间隔配置
心跳机制心跳请求
13
Offset提交策略
自动提交与手动提交 · 同步提交与异步提交 · Exactly-Once语义
Offset提交策略
14
消费者组边界定义
边界概念 · 静态成员与动态成员 · 边界变更场景
消费者组边界定义边界概念
15
静态分组与动态分组
Static Group Membe… · group.instance.id配…
静态分组动态分组
16
分区所有权
Partition Ownershi… · 所有权转移 · 冲突检测
分区所有权Partition
17
Go实现自定义分配器
实现sarama的BalanceSt… · 注册自定义策略
Go实现自定义分配器
18
消费者组监控
JMX指标 · Prometheus + Grafa… · 分配状态
消费者组监控JMX
19
故障场景分析
消费者崩溃 · 网络分区 · Broker宕机对分区分配的影响
故障场景分析消费者崩溃
20
再均衡优化
减少再均衡次数 · 增量再均衡 · 静态成员避免再均衡
再均衡优化减少再均衡次数
21
多消费者组共存
不同组消费同一Topic · 组间隔离性 · Offset独立管理
多消费者组共存Topic
22
分区扩展与收缩
增加分区 · 减少分区对消费者组分配的影响与处理
分区扩展收缩
23
Go测试消费者组
使用Sarama Mock · 单元测试与集成测试消费者组行为
Go测试消费者组
24
Kafka Streams与消费者组
Kafka Streams内部消费者… · 任务分配
KafkaStreams
25
跨数据中心消费者组
高延迟场景 · 异步复制 · 消费者组边界扩展
跨数据心消费者组
26
安全与认证
SASL/SSL配置 · ACL控制消费者组操作权限
安全认证
27
性能调优
Fetch大小 · Session超时 · MaxPollRecords参数调优
性能调优Fetch
28
实战案例一
日志收集系统 · 多分区多消费者组分配设计
实战案例一日志收集系统
29
实战案例二
实时计算引擎 · 基于Sticky分配器的状态恢复
实战案例二实时计算引擎
30
总结与最佳实践
常见陷阱 · 设计模式 · 未来演进（KIP-848等）
最佳实践常见陷阱