rocketmq CONSUME_FROM_LAST_OFFSET CONSUME_FROM_LAST_OFFSET
2017-12-05 20:37
1011 查看
3 ConsumeFromWhere consumeFromWhere
消费者从那个位置消费，分别为：
3.1 CONSUME_FROM_LAST_OFFSET：第一次启动从队列最后位置消费，后续再启动接着上次消费的进度开始消费
3.2 CONSUME_FROM_FIRST_OFFSET：第一次启动从队列初始位置消费，后续再启动接着上次消费的进度开始消费
3.3 CONSUME_FROM_TIMESTAMP：第一次启动从指定时间点位置消费，后续再启动接着上次消费的进度开始消费
以上所说的第一次启动是指从来没有消费过的消费者，如果该消费者消费过，那么会在broker端记录该消费者的消费位置，如果该消费者挂了再启动，那么自动从上次消费的进度开始，见RemoteBrokerOffsetStore
消费者从那个位置消费，分别为：
3.1 CONSUME_FROM_LAST_OFFSET：第一次启动从队列最后位置消费，后续再启动接着上次消费的进度开始消费
3.2 CONSUME_FROM_FIRST_OFFSET：第一次启动从队列初始位置消费，后续再启动接着上次消费的进度开始消费
3.3 CONSUME_FROM_TIMESTAMP：第一次启动从指定时间点位置消费，后续再启动接着上次消费的进度开始消费
以上所说的第一次启动是指从来没有消费过的消费者，如果该消费者消费过，那么会在broker端记录该消费者的消费位置，如果该消费者挂了再启动，那么自动从上次消费的进度开始，见RemoteBrokerOffsetStore
内容来自用户分享和网络整理，不保证内容的准确性，如有侵权内容，可联系管理员处理 
相关文章推荐
- rocketmq consumeLog
- rocketmq学习笔记 五 源码之rocketmq-tools
- rocketmq学习笔记 六 流程之取消息
- Spring 整合 RocketMQ
- MQ产品比较-ActiveMQ-RocketMQ
- RocketMQ原理解析-consumer 4.长轮询push消息—并发消费消息
- (2)Mysql ----- The last packet successfully received from the server was *** millisecond ago.The
- Linux安装RocketMQ
- mysql重连，连接丢失：The last packet successfully received from the server
- mysql重连，连接丢失：The last packet successfully received from the server
- RocketMQ原理（2）——核心概念及术语
- RocketMQ原理解析-producer 1.启动流程
- 分布式消息队列RocketMQ源码分析之1 -- Topic路由数据结构解析 -- topicRoute与topicPublishInfo与queueId
- Rocket MQ consumer 源码分析（绝对干货）
- 关于消息队列的使用----ActiveMQ，RabbitMQ，ZeroMQ，Kafka，MetaMQ，RocketMQ
- 消息队列选型[首选Kafka](备选:RabbitMQ/NSQ/RocketMQ/disque/Kafka)
- MQ选型对比RabbitMQ RocketMQ ActiveMQ Kafka
- RocketMQ 入门部署
- 【RocketMQ源码深度解析2】源码目录结构介绍&Remoting通信层
- 分布式消息队列RocketMQ&Kafka -- 消息的“顺序消费”-- 一个看似简单的复杂问题