问下Apache RocketMQ4.4版本 延时消息插入broker之后,由于msg的topic?[阿里云消息队列MQ]

问下Apache RocketMQ4.4版本 延时消息插入broker之后,由于msg的topic变成了SCHEDULE_TOPIC_XXXX,ScheduleMessageService到点后将消息put到真实的topic,但是没有纳入统计到BrokerStatsManager,所以延时消息这块通过BrokerStatsManager没法真实看到分钟/小时/天的统计,这块新版本有优化或者变化吗?

「点点赞赏,手留余香」

    还没有人赞赏,快来当第一个赞赏的人吧!
=====这是一个广告位,招租中,联系qq 78315851====
1 条回复 A 作者 M 管理员
  1. 对于Apache RocketMQ 4.4版本,延时消息插入broker后被分配到SCHEDULE_TOPIC_Xxxxx这个topic,然后由ScheduleMessageService按照延时时间再次发送到真实的目的topic。但是由于这个过程涉及到不同的topic,所以在BrokerStatsManager统计延时消息的时候会有一定的限制。因此,如果想要准确地统计延时消息的情况,建议使用专门的监控工具对SCHEDULE_TOPIC_Xxxxx和对应的真实目的topic进行监控和统计。

    在新版本的RocketMQ中,这种限制并没有被完全解决。但是可以通过启用trace log来获得更详细的延时消息日志信息,这些信息可以协助更好地统计和监控延时消息。同时,也可以参考RocketMQ社区开发的插件和工具来实现更高级别的监控和统计需求。