消息回溯
消息队列 CMQ 消息回溯功能 - 消息队列（Queue）模型 - 文档中心 - 腾讯云 https://cloud.tencent.com/document/product/406/8129 最近更新时间：2020-07-31 17:41:51 ...
原文：rocketMQ 消息回溯
rocketMQ 重置消息 offset，有两种情形：一种是有消费者在线，另一种则是无消费者在线。 命令行 首先描述存在在线消费者的情况： . 命令行程序和 nameserver 及 broker 交互 . broker 查询 topic 分区，指定时间的消息 offset，并通知连接该 broker 的 consumer . consumer 根据 broker 返回的 offsetTable ...
2020-01-14 15:05 0 2495 推荐指数：
相关推荐
RocketMQ源码 — 九、 RocketMQ延时消息
通过设置消息被投递的时间来实现的，但是Apache RocketMQ在版本4.2.0中尚不支持指定时间 ...
RocketMQ （三）RocketMQ 怎么保证的消息不丢失？
一、消息发送过程 我们将消息流程分为如下三大部分，每一部分都有可能会丢失数据。 生产阶段：Producer通过网络将消息发送给Broker，这个发送可能会发生丢失，比如网络延迟不可达等。 存储阶段：Broker肯定是先把消息放到内存的，然后根据刷盘策略持久化到硬盘中，刚收到 ...
rocketMQ(七) rocketMQ 消息端配置
一.消息队列RocketMQ4.X消费者核心配置讲解 consumeFromWhere配置(某些情况失效：参考 https://blog.csdn.net/a417930422/article/details/83585397 ...
RocketMQ源码 — 八、 RocketMQ消息重试
RocketMQ的消息重试包含了producer发送消息的重试和consumer消息消费的重试。 producer发送消息重试 producer在发送消息的时候如果发送失败了，RocketMQ会自动重试。 重试几次？ 由上面可以看出发送消息的重试次数区分不同的情况： 同步发送 ...
Kafka消息消息顺序、积压、回溯
顺序消息 kafka想要保证消息顺序，是需要牺牲一定性能的，方法就是一个消费者，消费一个分区，可以保证消费的顺序性。但也仅限于消费端消费消息的有序性，无法保证生产者发送消息有序。 比如：如果发送端配置了重试机制，kafka不会等之前那条消息完全发送成功才去发送下一条消息，这样可能会 ...
RocketMQ（二）事务消息&顺序消息
一、事务消息的由来 1、案例 引用官方的购物案例： 小明购买一个100元的东西，账户扣款100元的同时需要保证在下游的积分系统给小明这个账号增加100积分。账号系统和积分系统是两个独立是系统，一个要减少100元，一个要增加100积分。如下图： 2、问题 账号服务扣款成功 ...
rocketMq消息的发送和消息消费
rocketMq消息的发送和消息消费 ###一.消息推送 ```java public void pushMessage() { String message = "推送消息内容！"; try { DefaultMQProducer producer = new ...