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 条评论
下一页