《Kafka技术内幕》
Introduce
- Kafka介绍
- 使用Unix管道解释Kafka
- Kafka图文理解
源码分析汇总
- 生产者(java)
- 生产者(scala)
- 网络层SocketServer
- 消息存储到日志文件中
- Partition的ISR工作机制
- 消费者初始化(scala)
- 消费者抓取流程
Gitbook入口: https://www.gitbook.com/book/zqhxuyuan1/kafka/details
《Kafka技术内幕》章节
- Kafka入门
1.1 Introduce
1.2 QuickStart
1.3 Performance - 生产者√
2.1 新生产者
2.2 旧生产者
2.3 SocketServer - 存储√
3.1 KafkaApis
3.2 ReplicaManager
3.3 DelayedOperatiton - 消费者(低级和高级API)√
4.1 高级API
4.2 Consumer Fetcher
4.3 Consumer Offset
4.4 低级API - 新消费者√
5.1 KafkaConsumer
5.2 GroupCoordinator - 控制器 Controller√
6.1 KafkaController
6.2 LeaderAndISR - 连接器 Connect
- 流处理 Streams
- 工具 Tool
9.1 Admin Tool
9.2 Monitor - 生态系统 Ecosystem
10.1 Confluent
10.2 Storm
10.3 Spark
10.4 Samza
10.5 Flink
原文 http://zqhxuyuan.github.io/2017/01/01/Kafka-Code-Index/