- 卡夫卡消费者
offset值,消费到哪里了呢?之前存储在zookeeper,后面kafka保存在一个主题里,并持久化到硬盘,相当安全
- 消费者组ID 用命令行创建会默认给你一个
- cororifnator协调器,分区初始化对主题数50取模,选择有一个corrdinator
- 超高频面试题再平衡
保持3秒的心跳,namenode也是,再平衡就是将剩下的没挂的重新分配任务,超时45秒,处理超时5分钟
- 流程
- 消费策略
粘性策略
- offset 自动提交 0,9之前zookeeper
- 指定时间和offset值消费
6个组合拳