开发者社区 > 云原生 > 云消息队列 > 正文

RocketMQ消息轨迹问题,我用的是grpc,sdk好像无法开启消息轨迹。如何解决

RocketMQ消息轨迹问题
我用的是grpc,sdk好像无法开启消息轨迹。
remoting的是可以设置开启消息轨迹的。

展开
收起
嘟嘟嘟嘟嘟嘟 2023-09-27 09:35:59 180 0
1 条回答
写回答
取消 提交回答
  • RocketMQ的消息轨迹需要在Producer端开启,如果使用的是grpc,可以通过以下代码开启:

    public static void main(String[] args) {
    // 创建RocketMQClient
    DefaultMQProducer producer = new DefaultMQProducer("producer-group");
    // 设置namesrv的地址
    producer.setNamesrvAddr("localhost:9876");
    // 开启消息轨迹
    producer.setTraceEnable(true);
    // 发送消息
    producer.send(new Message("test", "tag", "Hello world".getBytes()));
    // 关闭Producer
    producer.shutdown();
    }

    2023-10-11 10:30:41
    赞同 展开评论 打赏

涵盖 RocketMQ、Kafka、RabbitMQ、MQTT、轻量消息队列(原MNS) 的消息队列产品体系,全系产品 Serverless 化。RocketMQ 一站式学习:https://rocketmq.io/

相关产品

  • 云消息队列 MQ
  • 相关电子书

    更多
    从 SDK 到编解码:视频直播架构解析 立即下载
    跨平台的云服务SDK需要什么 立即下载
    一个跨平台的云服务SDK需要什么 立即下载