来源：尚硅谷，Seven对其进行了补充完善
Kafka 生产者
生产者消息发送流程
发送原理
-
在消息发送的过程中，涉及到两个线程，main线程和sender线程，
-
main线程是消息的生产线程
-
sender线程是jvm单例的线程，专门用于消息的发送。
-
在jvm的内存中开辟了一块缓存空间叫RecordAccumulator（消息累加器），用于将多条消息合并成一个批次，然后由sender线程发送给kafka集群。
来源：尚硅谷，Seven对其进行了补充完善
Kafka基础架构
在Kafka2.8版本前，Zookeeper的Consumer文件中存放消息被消费的记录（offset）
在Kafka2.8版本走，消息被消费的记录（offset）存放在Kafka中。
引入依赖
<dependency>
<groupId>org.springframework.kafka</groupId>
<artifactId>spring-kafka</artifactId>
</dependency>基础
什么是消息队列
消息队列（Message Queue，简称MQ），指保存消息的一个容器，本质是个队列。
- 消息（Message）是指在应用之间传送的数据，消息可以非常简单，比如只包含文本字符串，也可以更复杂，可能包含嵌入对象。
- 消息队列（Message Queue）是一种应用间的通信方式，消息发送后可以立即返回，有消息系统来确保信息的可靠专递，消息发布者只管把消息发布到MQ中而不管谁来取，消息使用者只管从MQ中取消息而不管谁发布的，这样发布者和使用者都不用知道对方的存在。
一般包含以下三个角色：