1. 收不到消息-consumerOffset.json 信息错位 这种情况一般是，手动删除了store/commitlog目录里的数据等非常规手段造成了consumerOffset.json中记录的还是原来的信息，导致consumer收不到消息。 rocketmq的broker，一个消息主题 ...

1.为什么要用消息中间件： 1.解耦：　　 系统A只负责把数据写到队列中，谁想要或不想要这个数据(消息)，系统A一点都不关心。 　　　　　　即便现在系统D不想要userId这个数据 ...

RocketMQ日志 RocketMQ提供了一个日志模块，实现自定义的Appender，目的是为了将日志发送到MQ中。 可以参考文章https://blog.csdn.net/wanbf123/article/details/77988801 在RocketMQ的client模块中中 ...

RocketMQ相关问题 1、发送消息时tags参数疑惑 tags参数：在发送消息是，新建Message对象时，可以指定要发送到那个topic下。我的疑惑是：发送消息时，这个tags参数到底是指定一个还是可以指定多个。 先查看订阅消息方法源码： 注意到，第二个参数 ...

RocketMQ消息堆积问题 RocketMQ消息堆积主要分为三个层次的问题： 其一是Producer生产速率过快，什么场景呢，比如Producer故障，比如DOS攻击，比如业务高峰（超过企业预估的，例如12306订票，双十一下单，这些一开始的时候都有超过预期的情况）。 其二是Broker消息 ...

OK,我们在使用RocketMQ的Filter服务时候，需要注意一些问题，如题我们迅速开始吧！ 首先，我们需要启动我们的MQ服务，顺序为 namesrv、broker、filter。我配置的为：2m-2s-async（也就是两主两从模式） 我们需要在broker-*.properties文件里 ...

RocketMQ消息堆积的问题 1.发生的原因： 　　由于Consumer故障导致消费着节点全部宕机，生产者还在不停的投递消息到Broker，消息被挤压在Broker没有被消费； 2.消息堆积导致的问题: 　　过多的数据不仅占用磁盘空间，还会影响MQ性能； 3.解决方案： 　　分三种 ...

公司使用了最新的rocketmq框架，然后2天日志跑了快2个g。。。。 无奈网上只有4.2的教程。。。只好自己研究 环境rocketmq4.4 springboot 看源码找到配置日志等级和路径的地方（4.4和4.2是有区别的！） 可以看出是读取系统参数 ...