当前位置: 首页 > news >正文

RocketMQ生产者和消费者都开启Message Trace后,Consume Message Trace没有消费轨迹

一、依赖

<dependency><groupId>org.apache.rocketmq</groupId><artifactId>rocketmq-spring-boot-starter</artifactId><version>2.0.3</version>
</dependency>

二、场景

1、生产者和消费者所属同一个程序

2、生产者开启消息轨迹

DefaultMQProducer producer = new DefaultMQProducer(groupName, new AclClientRPCHook(new SessionCredentials("xxx", "xxx")), true, null);

3、消费者开启消息轨迹

DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("", config.getGroupName(), new AclClientRPCHook(new SessionCredentials("xxx", "xxx")), new AllocateMessageQueueAveragely(), true, null);

4、生产者和消费者一起开启后,在RocketMQ可视化界面,无法查看到消息的消费轨迹

注:如果只开启生产者或消费者其中之一的消息轨迹,则消息的消费轨迹是正常的

三、表现

无法展示消费轨迹

在这里插入图片描述

四、原因

具体原因不明确,通过更换RocketMQ依赖版本解决问题

五、解决

更换RocketMQ依赖版本,将2.0.3替换为2.2.3

<dependency><groupId>org.apache.rocketmq</groupId><artifactId>rocketmq-spring-boot-starter</artifactId><version>2.2.3</version>
</dependency>

更换后消息轨迹展示正常

在这里插入图片描述

http://www.lryc.cn/news/112776.html

相关文章:

  • JDV背后的技术-助力618 | 京东云技术团队
  • 0基础学习VR全景平台篇 第78篇:全景相机-拍摄VR全景
  • Spring MVC简介与概述
  • java基础复习(第六日)
  • 商用服务机器人公司【Richtech Robotics】申请纳斯达克IPO上市
  • 关于nn.Embedding如何使用预定义词表
  • 怎么设置文件夹密码?文件夹密码设置方法合集
  • PEMFC氢氧质子交换燃料电池MATLAB仿真模型
  • 创建PVC注意事项
  • Sencha Ext.NET Crack 快速应用程序的正确工具集
  • transformer学习
  • 基于LNMP架构搭建Discuz论坛
  • 乐鑫科技2021笔试题
  • VL 模型 Open-Set Domain Adaptation with Visual-Language Foundation Models 论文阅读笔记
  • 在IDEA同一个窗口中同时打开多个独立项目
  • flask-session、数据库连接池
  • 基于EEGLAB的ICA分析
  • Pytorch深度学习-----神经网络之线性层用法
  • 代码随想录算法训练营day58
  • Grafana集成prometheus(4.Grafana添加预警)
  • 宏观上看Spring创建对象的过程
  • Jtti:linux如何配置dns域名解析服务器
  • 上网速度慢解决方案
  • 解决 “fatal: Could not read from remote repository.
  • TypeScript知识点总结
  • Map简单介绍
  • Linux文本处理工具和正则表达式
  • 【WebRTC---源码篇】(二十三)JitterBuffer
  • 基于SpringBoot+Vue的在线考试系统设计与实现(源码+LW+部署文档等)
  • 用Rust实现23种设计模式之 外观模式