展开全部

主编推荐语

从架构设计到实现细节,从应用场景到核心概念,详细分析Kafka生产者、消费者、Server端源码。

内容简介

本书以Kafka0.10.0版本源码为基础,针对Kafka的架构设计到实现细节进行详细阐述。

本书共5章,从Kafka的应用场景、源码环境搭建开始逐步深入,对Kafka的核心概念进行分析介绍,对Kafka生产者、消费者、服务端的源码进行深入的剖析,最后介绍Kafka常用的管理脚本实现,让读者不仅从宏观设计上了解Kafka,而且能够深入到Kafka的细节设计之中。

本书为读者阅读Kafka源码提供帮助和指导,让读者更加深入地了解Kafka的运行原理、设计理念,让读者在设计分布式系统时可以参考Kafka的优秀设计。

目录

  • 版权信息
  • 内容简介
  • 前言
  • 如何阅读本书
  • 致谢
  • 读者服务
  • 专家推荐
  • 第1章 快速入门
  • 1.1 Kafka简介
  • 1.2 以Kafka为中心的解决方案
  • 1.3 Kafka核心概念
  • 1.4 搭建Kafka源码环境
  • 本章小结
  • 第2章 生产者
  • 2.1 KafkaProducer使用示例
  • 2.2 KafkaProducer分析
  • 2.2.1 ProducerInterceptors&ProducerInterceptor
  • 2.2.2 Kafka集群元数据
  • 2.2.3 Serializer&Deserializer
  • 2.2.4 Partitioner
  • 2.3 RecordAccumulator分析
  • 2.3.1 MemoryRecords
  • 2.3.2 RecordBatch
  • 2.3.3 BufferPool
  • 2.3.4 RecordAccumulator
  • 2.4 Sender分析
  • 2.4.1 创建请求
  • 2.4.2 KSelector
  • 2.4.3 InFlightRequests
  • 2.4.4 MetadataUpdater
  • 2.4.5 NetworkClient
  • 本章小结
  • 第3章 消费者
  • 3.1 KafkaConsumer使用示例
  • 3.2 传递保证语义(Delivery guarantee semantic)
  • 3.3 Consumer Group Rebalance设计
  • 3.4 KafkaConsumer分析
  • 3.4.1 ConsumerNetworkClient
  • 3.4.2 SubscriptionState
  • 3.4.3 ConsumerCoordinator
  • 3.4.4 PartitionAssignor分析
  • 3.4.5 Heartbeat分析
  • 3.4.6 Rebalance实现
  • 3.4.7 offset操作
  • 3.4.8 Fetcher
  • 3.4.9 KafkaConsumer分析总结
  • 本章小结
  • 第4章 Kafka服务端
  • 4.1 网络层
  • 4.1.1 Reactor模式
  • 4.1.2 SocketServer
  • 4.1.3 AbstractServerThread
  • 4.1.4 Acceptor
  • 4.1.5 Processor
  • 4.1.6 RequestChannel
  • 4.2 API层
  • 4.2.1 KafkaRequestHandler
  • 4.2.2 KafkaApis
  • 4.3 日志存储
  • 4.3.1 基本概念
  • 4.3.2 FileMessageSet
  • 4.3.3 ByteBufferMessageSet
  • 4.3.4 OffsetIndex
  • 4.3.5 LogSegment
  • 4.3.6 Log
  • 4.3.7 LogManager
  • 4.4 DelayedOperationPurgatory组件
  • 4.4.1 TimingWheel
  • 4.4.2 SystemTimer
  • 4.4.3 DelayedOperation
  • 4.4.4 DelayedOperationPurgatory
  • 4.4.5 DelayedProduce
  • 4.4.6 DelayedFetch
  • 4.5 副本机制
  • 4.5.1 副本
  • 4.5.2 分区
  • 4.5.3 ReplicaManager
  • 4.6 KafkaController
  • 4.6.1 ControllerChannelManager
  • 4.6.2 ControllerContext
  • 4.6.3 ControllerBrokerRequestBatch
  • 4.6.4 PartitionStateMachine
  • 4.6.5 PartitionLeaderSelector
  • 4.6.6 ReplicaStateMachine
  • 4.6.7 ZooKeeper Listener
  • 4.6.8 KafkaController初始化与故障转移
  • 4.6.9 处理ControlledShutdownRequest
  • 4.7 GroupCoordinator
  • 4.7.1 GroupMetadataManager
  • 4.7.2 GroupCoordinator分析
  • 4.8 身份认证与权限控制
  • 4.8.1 配置SASL/PLAIN认证
  • 4.8.2 身份认证
  • 4.8.3 权限控制
  • 4.9 Kafka监控
  • 4.9.1 JMX简介
  • 4.9.2 Metrics简介
  • 4.9.3 Kafka中的Metrics
  • 4.9.4 Kafka的监控功能
  • 4.9.5 监控KSelector的指标
  • 第5章 Kafka Tool
  • 5.1 kafka-schmerver-start脚本
  • 5.2 kafka-topics脚本
  • 5.2.1 创建Topic
  • 5.2.2 修改Topic
  • 5.3 kafka-preferred-replica-election脚本
  • 5.4 kafka-reassign-partitions脚本
  • 5.5 kafka-console-producer脚本
  • 5.6 kafka-console-consumer脚本
  • 5.7 kafka-consumer-groups脚本
  • 5.8 DumpLogSegments
  • 5.9 kafka-producer-perf-test脚本
  • 5.10 kafka-consumer-perf-test脚本
  • 5.11 kafka-mirror-maker脚本
  • 本章小结
  • 参考文献
  • 参考书籍
  • 参考网络资源
展开全部

评分及书评

尚无评分
目前还没人评分

出版方

电子工业出版社

电子工业出版社成立于1982年10月,是国务院独资、工信部直属的中央级科技与教育出版社,是专业的信息技术知识集成和服务提供商。经过三十多年的建设与发展,已成为一家以科技和教育出版、期刊、网络、行业支撑服务、数字出版、软件研发、软科学研究、职业培训和教育为核心业务的现代知识服务集团。出版物内容涵盖了电子信息技术的各个分支及工业技术、经济管理、科普与少儿、社科人文等领域,综合出版能力位居全国出版行业前列。