大厂也在用的6种数据脱敏方案，已有千人收藏
作者：互联网
# 第1章快速入门
**1.1 Kafka简介**
**1.2 以Kafka为中心的解决方案**
**1.3 Kafka核心概念**
**1.4 Kafka源码环境**
# 第2章生产者
**2.1 KafkaProducer 使用示例**
**2.2 KafkaProducer 分析**
* ProducerInterceptors&cProducerInterceptor
* Kafka 集群元数据
* Serializer&Deserializer
* Partitioner
**2.3 RecordAccumulator分析**
* MemoryR ecords
* RecordBatch
* BufferPool
* RecordAccumulator
**2.4 Sender分析**
* 创建请求
* KSelector
* InFlightRequests
* MetadataUpdater
* NetworkClient
# 第3章消费者
**3.1 KafkaConsumer 使用示例**
**3.2 传递保证语义( Delivery guarantee semantic )**
**3.3 Consumer Group Rebalance设计**
**3.4 KafkaConsumer 分析**
* ConsumerNetworkC lient
* SubscriptionState
* ConsumerCoordinator.
* PartitionAssignor 分析
* Heartbeat 分析
* Rebalance 实现
* offset 操作
* Fetcher
* KafkaConsumer 分析总结
# 第4章Kafka服务端
**4.1 网络层**
* Reactor模式
* SocketServer
* AbstractServer Thread
* Acceptor
* Processor
* RequestChannel
**4.2 API层**
KafkaR equestHandler
KafkaApis
**4.3 日志存储**
* 基本概念
* FileMessageSet
* ByteBufferMessageSet
* OfsetIndex
* LogSegment
* Log
* LogManager
**4.4 DelayedOperationPurgatory 组件**
* TimingWheel
* SystemTimer
* Delayed Dperation
* DelayedOperationPurgatory
* DelayedProduce
* DelayedFetch
**4.5 副本机制**
* 副本
* 分区
* ReplicaManager
**4.6 KafkaController**
* ControllerChannelManager
* ControllerContext
* ControllerBrokerRequestBatch
* PartitionStateMachine
* PartitionLeaderSelector
* ReplicaStateMachine
* ZooKeeper Listener
* KafkaController 初始化与故障转移
* 处理ContolledShutdownRequest
**4.7 GroupCoordinator**
* GroupMetadataManager
* GroupCoordinator分析
**4.8 身份认证与权限控制**
* 配置SASL/PLAIN认证
* 身份认证
* 权限控制
**4.9 Kafka 监控**
* JMX 简介
* Metrics简介
* Kafka中的Metrics
* Kafka的监控功能
* 监控KSelector的指标
# 第5章Kafka Tool
**5.1 kafka-server-start 脚本**
**5.2 kafka-topics 脚本**
* 创建Topic
* 修改Topic
**5.3kafka-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.11kafka-mirror-maker脚本**
# 最后分享一波我的面试宝典——一线互联网大厂Java核心面试题库
**以下是我个人的一些做法，希望可以给各位提供一些帮助：**
> **[点击《一线互联网大厂Java核心面试题库》即可免费领取](https://docs.qq.com/doc/DSmxTbFJ1cmN1R2dB)**，整理了很长一段时间，拿来复习面试刷题非常合适，其中包括了Java基础、异常、集合、并发编程、JVM、Spring全家桶、MyBatis、Redis、数据库、中间件MQ、Dubbo、Linux、Tomcat、ZooKeeper、Netty等等，且还会持续的更新...可star一下！
**283页的Java进阶核心pdf文档**
> Java部分：Java基础，集合，并发，多线程，JVM，设计模式
>
> 数据结构算法：Java算法，数据结构
>
> 开源框架部分：Spring，MyBatis，MVC，netty，tomcat
>
> 分布式部分：架构设计，Redis缓存，Zookeeper，kafka，RabbitMQ，负载均衡等
>
> 微服务部分：SpringBoot，SpringCloud，Dubbo，Docker
**还有源码相关的阅读学习**
标签：20210706,s2.51,Kafka,千人,大厂,https,cto,com,脱敏 来源： https://blog.51cto.com/u_15290979/2985339