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

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

展开
收起
嘟嘟嘟嘟嘟嘟 2023-09-27 09:35:59 227 分享 版权
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-learning.com/

热门讨论

热门文章

还有其他疑问?
咨询AI助理