上一节咱们次要剖析了RecordAccumulator通过BufferPool申请内存的源码原理，在之前的剖析中，在KafkaProducer发送音讯时，把音讯放入内存缓冲区中次要分为了三步。如下：

之前咱们剖析了Producer的配置解析、组件剖析、拉取元数据、音讯的初步序列化形式、音讯的路由策略。如下图：这一节咱们持续剖析发送音讯的内存缓冲器原理—RecordAccumulator.append()。如何将音讯放入内存缓冲器的？在doSend中的，拉取元数据、音讯的初步序列化形式、音讯的路由策略之后就是accumulator.append()。如下…

Kafka成长记的前4节咱们通过KafkaProducerHelloWorld剖析了Producer配置解析、组件组成、元数据拉取原理。但KafkaProducerHelloWorld发送音讯的代码并没有剖析完，咱们剖析了如到了如下图所示的地位：接下来，咱们持续往下剖析，这一节咱们次要剖析下发送音讯的初步序列化和分区路由源码原理。自定义音讯的初步序列化的…

上一节结尾，咱们总结道： 初始化KafkaProducer时并没有去拉取元数据，然而创立了Selector组件，启动了Sender线程，select阻塞期待申请响应。因为还没有发送任何申请，所以初始化时并没有去真正拉取元数据。

上一节咱们剖析了Producer的外围组件，咱们失去了一张要害的组件图。你还记得么？简略概括下下面的图就是：创立了Metadata组件，外部通过Cluster保护元数据初始化了发送音讯的内存缓冲器RecordAccumulator创立了NetworkClient，外部最重要的是创立了NIO的Selector组件启动了一个Sender线程，Sender援用了下面的所有组件…

上一节咱们次要从HelloWorld开始，剖析了Kafka Producer的创立，重点剖析了如何解析生产者配置的源码原理。 {代码…} Kafka Producer的创立除了配置解析，还有要害的一步就是调用了一个重载的构造函数。这一节咱们就来看下它次要做了什么。KafkaProducer初始化的哪些组件？既然时一个要害组件创立，剖析的构造函数，我…

下面的逻辑只是Accumulator.append()的一段外围逻辑而已，还记得之前咱们剖析过的KafkaProducerHelloWorld的整体逻辑么？

明天给大家分享一份《SpringBoot+Vue全栈开发实战》电子书，通过本书你能够把握Spring Boot全栈开发流程,独立实现大型SPA利用

上一节咱们提到过，意识一个新技术的时候，通常是从一个入门的HelloWorld开始，之后浏览它的一些入门文档和书籍、视频，从而把握它的根本应用。

成长记不会介绍太多一些kafka的基础知识，如果有需要的话，之后会有专门的《小白起步营》。成长记的默认大家对kafka的一些概念是熟知的、默认也是会根本Kafka的部署的。当然为了关照一些小白，第一次波及的常识我会简略介绍和解释的，相熟的人就当回顾吧。简略的事件反复做有时也是坏事。