AI
推荐
模板社区
专题
登录
免费注册
首页
流程图
详情
kafka消息消费流程
2022-03-25 12:39:48
16
举报
分享方式
免费使用
kafka消息消费流程
kafka
MQ
消息
java
模版推荐
作者其他创作
大纲/内容
group2
consumer
消息被用户组groupid1消费
group1
网卡
consumer1-3
consumer1-2
1、sync函数sync函数只是将所有修改过的块缓冲区排入写队列，然后就返回，它并不等待实际写磁盘操作结束。通常称为update的系统守护进程会周期性地（一般每隔30秒）调用sync函数。这就保证了定期冲洗内核的块缓冲区。命令sync(1)也调用sync函数。2、fsync函数fsync函数只对由文件描述符filedes指定的单一文件起作用，并且等待写磁盘操作结束，然后返回。fsync可用于数据库这样的应用程序，这种应用程序需要确保将修改过的块立即写到磁盘上。
磁盘
数据拷贝
只能被一个此组中的一个消费
时间周期：fsync
磁盘读取
读取内存
consumer2-3
Kafka
consumer2-2
os cache 缓存读取数据
consumer1-1
消息被用户组groupid2消费
消费数据
socket cache
topic1
consumer2-1
零拷贝
收藏
立即使用
kafka消息消费流程
收藏
立即使用
AOF和RDF
收藏
立即使用
redis高可用
收藏
立即使用
cas
拔土豆的程序员
职业：java工程师
去主页
Collect
Get Started
kafka消费组消费
Collect
Get Started
kafka 消息顺序
Collect
Get Started
Kafka消息中间件消息传递示意图
Collect
Get Started
Kafka消息引擎
评论
0
条评论
下一页
Document
