刷盘方式 博客分类: kafka
程序员文章站
2024-03-19 15:53:28
...
刷盘方式
同步刷盘:在消息到达MQ后,RocketMQ需要将数据持久化,同步刷盘是指数据到达内存之后,必须刷到commitlog日志之后才算成功,然后返回producer数据已经发送成功。
异步刷盘:,同步刷盘是指数据到达内存之后,返回producer说数据已经发送成功。,然后再写入commitlog日志。
commitlog:
commitlog就是来存储所有的元信息,包含消息体,类似于MySQL、Oracle的redolog,所以主要有CommitLog在,Consume Queue即使数据丢失,仍然可以恢复出来。
consumequeue:记录数据的位置,以便Consume快速通过consumequeue找到commitlog中的数据
推荐阅读
-
ERROR consumer thread timing out (kafka.tools.ReplayLogProducer$ZKConsumerThrea 博客分类: kafka
-
刷盘方式 博客分类: kafka
-
java读取文件和写入文件的方式 博客分类: JAVA
-
hibernate 注解方式实现联合主键 博客分类: Hibernate hibernate注解联合主键
-
Java中创建对象的5种方式 博客分类: java基础
-
hibernate 注解方式实现联合主键 博客分类: Hibernate hibernate注解联合主键
-
Java io nio netty三种方式实现简单聊天功能 博客分类: java基础 ionionetty聊天
-
【转】vmware使用nat模式下的固定ip方式上网 博客分类: Linux/Win vmwareCentOS
-
Lucene其他查询方式 博客分类: Lucene lucene
-
tomcat下jndi的三种配置方式 博客分类: Web&App Server tomcatjndi数据源