Kafka源码解析与实战

作品简介

本书将从初学者的角度出发，循序渐进地讲解Kafka内部的实现原理，但是由于Kafka是基于Scala语言编写的，因此为了更好地阅读本书，希望读者对于Scala语言有大致的了解。

本书从LinkedIn（领英）公司内部大数据架构讲起，引出消息队列Kafka，接着讲解Kafka的基本架构，然后着重分析Kafka内部的各模块实现细节。从诞生背景至架构组成，再到内部实现细节，由浅入深，循序渐进，让读者在阅读时能够逐步了解Kafka。

作品目录

• 序
• 前言
• 第1章 Kafka简介
• 1.1 Kafka诞生的背景
• 1.2 Kafka在LinkedIn内部的应用
• 1.3 Kafka的主要设计目标
• 1.4 为什么使用消息系统
• 1.5 本章小结
• 第2章 Kafka的架构
• 2.1 Kafka的基本组成
• 2.2 Kafka的拓扑结构
• 2.3 Kafka内部的通信协议
• 2.4 本章小结
• 第3章 Broker概述
• 3.1 Broker的启动
• 3.2 Broker内部的模块组成
• 3.3 本章小结
• 第4章 Broker的基本模块
• 4.1 SocketServer
• 4.2 KafkaRequestHandlerPool
• 4.3 KafkaApis
• 4.4 KafkaHealthcheck
• 4.5 TopicConfigManager
• 4.6 本章小结
• 第5章 Broker的控制管理模块
• 5.1 KafkaController的选举策略
• 5.2 KafkaController的初始化
• 5.3 Topic的分区状态转换机制
• 5.4 Topic分区的领导者副本选举策略
• 5.5 Topic分区的副本状态转换机制
• 5.6 KafkaController内部的监听器
• 5.7 Kafka集群的负载均衡流程
• 5.8 Kafka集群的Topic删除流程
• 5.9 KafkaController的通信模块
• 5.10 本章小结
• 第6章 Topic的管理工具
• 6.1 kafka-topics.sh
• 6.2 kafka-reassign-partitions.sh
• 6.3 kafka-preferred-replica-election.sh
• 6.4 本章小结
• 第7章 生产者
• 7.1 设计原则
• 7.2 示例代码
• 7.3 模块组成
• 7.4 发送模式
• 7.5 本章小结
• 第8章 消费者
• 8.1 简单消费者
• 8.2 高级消费者
• 8.3 本章小结
• 第9章 Kafka的典型应用
• 9.1 Kafka和Storm的集成
• 9.2 Kafka和ELK的集成
• 9.3 Kafka和Hadoop的集成
• 9.4 Kafka和Spark的集成
• 9.5 本章小结
• 第10章 Kafka的综合实例
• 10.1 安防大数据的主要应用
• 10.2 Kafka在安防整体解决方案中的角色
• 10.3 典型业务
• 10.4 本章小结