前言

今天这篇文章是比较偏“教程”一点的文章。但也由浅入深，认真地分析了源码，并且介绍了一些在使用Spring Cache中常见的问题和解决方案，肯定是比简单的入门文档更有深度一些的，相信大家看了之后会有一定的收获。

那么，如何学习Kafka源码？？

我觉得最高效的方式就是去读最核心的源码，先看一张 Kafka结构图 以及 Kafka 源码全景图

梳理一下关于 Kafka 框架，找到学习的重点。

其次，我要说的就是一个Kafka源码解析的文档——《Kafka源码解析与实战》

前5章分别是：Kafka简介、Kafka的架构、Broker概述、Broker的基本模块、Broker的控制管理模块

**第1章 Kafka简介：**介绍Kafka诞生的背景、Kafka在LinkedIn内部的应用、Kafka 的主要设计目标以及为什么使用消息系统
**第2章 Kafka的架构：**介绍Kafka的基本组成、拓扑结构及其内部的通信协议
**第3章 Broker概述：**描述Kafka集群组成的基本元素Broker Server的启动以及内部的模块组成
**第4章 Broker的基本模块：**描述Broker Server内部的九大基本模块: SocketServer 、KafkaRequestHandlerPool 、LogManager、ReplicaManager 、OffsetManager、KafkaScheduler. KafkaApis 、KafkaHalthcheck和TopicConfigManager
**第5章 Broker的控制管理模块：**介绍BrokerServer的控制管理模块KafkaController,这个模块负责整个Kafka集群的管理，例如:Topic的新建和删除.分区状态和副本状态的转换、集群的负载均衡管理等

后5章分别是 Topic的管理工具、生产者、消费者、Kafka的典型应用、Kafka的综合案例

**第6章 Topic的管理工具：**介绍三个维护脚本: kafka-topics.sh 、kafka-reassign-partitions.sh 和kafka preferredreplica-election.sh,它们分别涉及Topic的生命周期管理、Topic分区的重分配和分区首选副本的选择。
**第7章生产者：**从设计原则、示例代码、模块组成和发送模式四个部分介绍有关消息生产者的相关知识，从设计原则至客户端编程，从客户端编程到内部实现原理，由浅人深，循序渐进地讲解。
**第8章消费者：**分别介绍两种消费者:简单消费者和高级消费者。针对每种消费者都将依次从设计原则、消费者流程、示例代码以及原理解析四个部分介绍消费者的相关知识。
**第9章 Kafka的典型应用：**介绍Kafka与典型大数据系统的集成，包括: Kafka和Storm的集成、Kafka 和ELK的集成、Kafka和Hadoop的集成以及Kafka和Spark的集成。
**第10章 Kafka的综合案例：**用综合实例描述了Kafka的应用，案例描述Kafka作为数据总线在安防整体解决方案中的作用，通过车辆人脸图片数据的入库、视频数据的入库、数据延时的监控、数据质量的监控、布控统计和容灾备份6个业务，简要阐述内部的实现原理。

再者就是关于Kafka的面试

Kafka面试专题解析

Kafka 的设计时什么样的呢？
数据传输的事物定义有哪三种？
Kafka 判断一个节点是否还活着有那两个条件？
producer 是否直接将数据发送到 broker 的 leader(主节点)？
Kafa consumer 是否可以消费指定分区消息？
Kafka 消息是采用 Pull 模式，还是 Push 模式？
Kafka 存储在硬盘上的消息格式是什么？
Kafka 高效文件存储设计特点
Kafka 与传统消息系统之间有三个关键区别
Kafka 创建 Topic 时如何将分区放置到不同的 Broker 中
Kafka 新建的分区会在哪个目录下创建
partition 的数据如何保存到硬盘
kafka 的 ack 机制
Kafka 的消费者如何消费数据
消费者负载均衡策略
数据有序
kafaka 生产数据时数据的分组策略

复习学习必备44个Kafka知识点（基础+进阶+高级）

Kafka基础篇知识点（17）

Kafka进阶篇知识点（15）

Kafka高级篇知识点（12）

44个Kafka知识点（基础+进阶+高级）解析如下

给大家分享下我的复习的面试资料

这些面试全部出自大厂面试真题和面试合集当中，小编已经为大家整理完毕（PDF版）

资料获取方式：戳这里前往我的腾讯文档免费下载

第一部分：Java基础-中级-高级

第二部分：开源框架（SSM：Spring+SpringMVC+MyBatis）

第三部分：性能调优（JVM+MySQL+Tomcat）

第四部分：分布式（限流：ZK+Nginx；缓存：Redis+MongoDB+Memcached；通讯：MQ+kafka）

第五部分：微服务（SpringBoot+SpringCloud+Dubbo）

第六部分：其他：并发编程+设计模式+数据结构与算法+网络

进阶学习笔记pdf

都已整理好，需免费下载点击这里即可

Java架构进阶之架构筑基篇（Java基础+并发编程+JVM+MySQL+Tomcat+网络+数据结构与算法）

Java架构进阶之开源框架篇（设计模式+Spring+SpringMVC+MyBatis）

Java架构进阶之分布式架构篇（限流（ZK/Nginx）+缓存（Redis/MongoDB/Memcached）+通讯（MQ/kafka））

Java架构进阶之微服务架构篇（RPC+SpringBoot+SpringCloud+Dubbo+K8s）

621930889585)]

Java架构进阶之微服务架构篇（RPC+SpringBoot+SpringCloud+Dubbo+K8s）

[外链图片转存中…(img-0ZIhS2El-1621930889586)]

[外链图片转存中…(img-yKp1hp88-1621930889587)]

javaweb项目完整案例下载，真的太香了！相关推荐

20套初级javaweb项目开发案例（适合白小）——计算机毕业设计
20套javaweb项目开发案例,数据库是mysql.有jsp+servlet,ssh和ssm项目.纯项目源码,配套详细项目讲解说明.适合初学者使用.可以用作课题项目,期末作业等
javaweb面试问题大全及答案大全，真的太香了！
整理的70道阿里的Java面试题,都来挑战一下,看看自己有多厉害. 1.java事件机制包括哪三个部分?分别介绍. 2.为什么要使用线程池? 3.线程池有什么作用? 4.说说几种常见的线程池及使用场景 ...
java语言的主要特点是什么，真的太香了！
拼多多二面:多线程+乐观锁和悲观锁+并发. 一面 1.并发编程三要素? 2.实现可见性的方法有哪些? 3.多线程的价值? 4.创建线程的有哪些方式? 5.创建线程的三种方式的对比? 6.什么是线程池? ...
干货来袭！初步理解类加载运行机制和类加载过程，真的太香了！
开头被面试人是我的一位粉丝近期刚刚结束了蚂蚁金服的三轮技术面试,面完之后他跟我说很累,直言不想再体验了. 他的面试经历我仔细看了看,一面重点在基础知识的考查,二面重点在项目以及对框架的使用与理解上, ...
如此优秀，这18个 Python 高效编程技巧真的太香了
初识 Python 语言,觉得 Python 满足了我上学时候对编程语言的所有要求.python语言的高效编程技巧让我们这些大学曾经苦逼学了四年c或者c++的人,兴奋的不行不行的,终于解脱了. 高级语 ...
java从入门到精通pdf下载，太香了
蚂蚁金服一面(技术面) JVM 内存分哪几个区,每个区的作用是什么?JVM有哪些回收算法,对应的收集器有哪些? GC 的两种判定方法 ?CMS 收集器与 G1 收集器的特点. hashmap源码问题 ...
NullPointerException 的处理新方式，Java14 真的太香了！
点击上方"方志朋",选择"设为星标" 回复"666"获取新整理的面试文章来源:锅外的大佬 1.传统的 NullPointerExcepti ...
NullPointerException的处理新方式，Java14真的太香了
在Java语言中,处理空指针往往是一件很头疼的事情,一不小心,说不定就搞出个线上Bug,让你的绩效考核拿到3.25.最近新出的Java14,相信大家都有所耳闻,那么今天就来看看,面对NullPoint ...
机器学习项目完整案例:预测区域的房价中位数
向AI转型的程序员都关注了这个号

javaweb项目完整案例下载，真的太香了！

前言