kafka消息消费流程

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

零拷贝