kafka基础逻辑结构图

Broker

2

msg deque

思考：为啥要搞一个Batch？其实很好理解，你一秒钟可以产生1w个消息，但是难道你要发送一万次请求到broker吗？所以，其实可将很多小的record打包成大的batch一起发，这样减少网络请求，提升吞吐量！

1

消息体

send

分区号

pull

Consumer

3

zookeeper

主题

topic

patition

headers

key

value

timestamp

Producer

一条消息的基本信息 -  ProducerRecord

消息发送的时间

ProducerBatch

4

kafka cluster

detail

归类用使用也可以不设置

消息头一般很少设置