kafka基础逻辑结构图
2021-09-01 17:14:10 9 举报
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
归类用使用也可以不设置
消息头一般很少设置
0 条评论
回复 删除
下一页
