RECONSUME_LATER

Failure consumption,later try to consume.

================MessageExt [queueId=0, storeSize=134, queueOffset=2, sysFlag=0, bornTimestamp=1442224189878, bornHost=/172.16.10.103:41609, storeTimestamp=1442224186835, storeHost=/172.16.50.62:10911, msgId=AC10323E00002A9F0000000000983278, commitLogOffset=9974392, bodyCRC=212786421, reconsumeTimes=0, preparedTransactionOffset=0, toString()=Message [topic=MyTopic, flag=0, properties={TAGS=MyTag, WAIT=true, MAX_OFFSET=3, MIN_OFFSET=0}, body=15]]

================MessageExt [queueId=0, storeSize=274, queueOffset=2, sysFlag=0, bornTimestamp=1442224189878, bornHost=/172.16.10.103:41609, storeTimestamp=1442224196880, storeHost=/172.16.50.62:10911, msgId=AC10323E00002A9F000000000098340D, commitLogOffset=9974797, bodyCRC=212786421, reconsumeTimes=1, preparedTransactionOffset=0, toString()=Message [topic=MyTopic, flag=0, properties={DELAY=3, ORIGIN_MESSAGE_ID=AC10323E00002A9F0000000000983278, REAL_TOPIC=%RETRY%MyConsumerGroup, TAGS=MyTag, WAIT=false, RETRY_TOPIC=MyTopic, MAX_OFFSET=3, MIN_OFFSET=0, REAL_QID=0}, body=15]]

================MessageExt [queueId=0, storeSize=274, queueOffset=3, sysFlag=0, bornTimestamp=1442224189878, bornHost=/172.16.10.103:41609, storeTimestamp=1442224227381, storeHost=/172.16.50.62:10911, msgId=AC10323E00002A9F000000000098362E, commitLogOffset=9975342, bodyCRC=212786421, reconsumeTimes=2, preparedTransactionOffset=0, toString()=Message [topic=MyTopic, flag=0, properties={DELAY=4, ORIGIN_MESSAGE_ID=AC10323E00002A9F0000000000983278, REAL_TOPIC=%RETRY%MyConsumerGroup, TAGS=MyTag, WAIT=false, RETRY_TOPIC=MyTopic, MAX_OFFSET=4, MIN_OFFSET=0, REAL_QID=0}, body=15]]

================MessageExt [queueId=0, storeSize=274, queueOffset=4, sysFlag=0, bornTimestamp=1442224189878, bornHost=/172.16.10.103:41609, storeTimestamp=1442224287440, storeHost=/172.16.50.62:10911, msgId=AC10323E00002A9F000000000098384F, commitLogOffset=9975887, bodyCRC=212786421, reconsumeTimes=3, preparedTransactionOffset=0, toString()=Message [topic=MyTopic, flag=0, properties={DELAY=5, ORIGIN_MESSAGE_ID=AC10323E00002A9F0000000000983278, REAL_TOPIC=%RETRY%MyConsumerGroup, TAGS=MyTag, WAIT=false, RETRY_TOPIC=MyTopic, MAX_OFFSET=5, MIN_OFFSET=0, REAL_QID=0}, body=15]]

================MessageExt [queueId=0, storeSize=274, queueOffset=5, sysFlag=0, bornTimestamp=1442224189878, bornHost=/172.16.10.103:41609, storeTimestamp=1442224407558, storeHost=/172.16.50.62:10911, msgId=AC10323E00002A9F0000000000983A70, commitLogOffset=9976432, bodyCRC=212786421, reconsumeTimes=4, preparedTransactionOffset=0, toString()=Message [topic=MyTopic, flag=0, properties={DELAY=6, ORIGIN_MESSAGE_ID=AC10323E00002A9F0000000000983278, REAL_TOPIC=%RETRY%MyConsumerGroup, TAGS=MyTag, WAIT=false, RETRY_TOPIC=MyTopic, MAX_OFFSET=6, MIN_OFFSET=0, REAL_QID=0}, body=15]]

时间: 2024-10-12 08:09:40

RECONSUME_LATER的相关文章

RocketMQ简单实现

生产者代码: import org.apache.rocketmq.client.exception.MQBrokerException; import org.apache.rocketmq.client.exception.MQClientException; import org.apache.rocketmq.client.producer.DefaultMQProducer; import org.apache.rocketmq.client.producer.SendResult;

RocketMQ实战(二)

在上一篇<RocketMQ实战(一)>中已经为大家初步介绍了下RocketMQ以及搭建了双Master环境,接下来继续为大家介绍! Quick Start 写一个简单的生产者.消费者,带大家快速体验RocketMQ~ Maven配置: 生产者: 消费者: 无论生产者.消费者都必须给出GroupName,而且具有唯一性! 生产到哪个Topic的哪个Tag下,消费者也是从Topic的哪个Tag进行消费,可见这个Tag有点类似于JMS Selector机制,即实现消息的过滤. 生产者.消费者需要设置

RocketMQ事务消费和顺序消费详解

一.RocketMq有3中消息类型 1.普通消费 2. 顺序消费 3.事务消费 顺序消费场景 在网购的时候,我们需要下单,那么下单需要假如有三个顺序,第一.创建订单 ,第二:订单付款,第三:订单完成.也就是这个三个环节要有顺序,这个订单才有意义.RocketMQ可以保证顺序消费. rocketMq实现顺序消费的原理 produce在发送消息的时候,把消息发到同一个队列(queue)中,消费者注册消息监听器为MessageListenerOrderly,这样就可以保证消费端只有一个线程去消费消息

Rocket重试机制,消息模式,刷盘方式

一.Consumer 批量消费(推模式) 可以通过 consumer.setConsumeMessageBatchMaxSize(10);//每次拉取10条 这里需要分为2种情况 Consumer端先启动 Consumer端后启动.   正常情况下:应该是Consumer需要先启动 注意:如果broker采用推模式的话,consumer先启动,会一条一条消息的消费,consumer后启动会才用批量消费 Consumer端先启动 1.Consumer.java package quickstart

RocketMQ快速入门

前面几篇文章介绍了为什么选择RocketMQ,以及与kafka的一些对比: 阿里 RocketMQ 优势对比,方便大家对于RocketMQ有一个简单的整体了解,之后介绍了:MQ 应用场景,让我们知道MQ在什么时候可以使用,可以解决什么问题,之后介绍了:RocketMQ集群部署配置:本篇文章接着上篇内容之后,来给大家介绍下RocketMQ快速入门. 如何使用 1.引入 rocketmq-client <dependency> <groupId>org.apache.rocketmq&

RocketMQ-广播模式消费

Rocketmq 消费者默认是集群的方式消费的,消费者还可以用广播的模式进行消费.广播模式消费就是所有订阅同一个主题的消费者都会收到消息.代码实现上其实很简单,就是在消费端添加 consumer.setMessageModel(MessageModel.BROADCASTING); 就可以了.我们看实验步骤: 一.启动ConsumerBroadCastMember1 二.启动ConsumerBroadCastMember2 三.运行ProducerBraodCast 四.我们可以看到两个Cons

RocketMQ-事务消费

理论部分在https://www.jianshu.com/p/453c6e7ff81c中的 "三.事务消息".下面从代码层面看一下rockemq的事务消息 一.事务消费端. 从代码中看到跟其他模式的消费端没有什么两样. package org.hope.lee.consumer.transaction; import com.alibaba.rocketmq.client.consumer.DefaultMQPushConsumer; import com.alibaba.rocket

RocketMQ(2)

1. 消费端集群消费(负载均衡) 示例代码: /** * Producer,发送消息 * */ public class Producer { public static void main(String[] args) throws MQClientException, InterruptedException { DefaultMQProducer producer = new DefaultMQProducer("message_producer"); producer.setN

RocketMQ-quickstart(批量消费)

一.专业术语 Producer 消费生产者,负责产生消息,一般由业务系统负责产生消息 Consumer 消息消费者,负责消费消息,一般是后台系统负责异步消费 Push Consumer Consumer的一种,应用通常向Consumer对象注册一个Listener接口,一旦收到消息,Consumer对象立刻回调Listener接口方法 Pull Consumer Consumer的一种,应用通常主动调用Consumer的拉消息方法,从Broker拉消息,主动权由应用控制 Producer Gro