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

rocketmq-client-java 5.0.7版本如何开启消息轨迹

已解决

依赖如下

        <dependency>
            <groupId>org.apache.rocketmq</groupId>
            <artifactId>rocketmq-client-java</artifactId>
            <version>5.0.7</version>
        </dependency>

在其他回答中看到有人说可以调用Producer#setTraceOn(true)开启消息轨迹,但是我查看Producer接口只有下面的方法,没有提到的方法。


    SendReceipt send(Message message) throws ClientException;


    SendReceipt send(Message message, Transaction transaction) throws ClientException;


    CompletableFuture<SendReceipt> sendAsync(Message message);

    Transaction beginTransaction() throws ClientException;

    @Override
    void close() throws IOException;

我想请问下在当前版本下如何开启消息轨迹呢?还是说当前版本特性并未迭代完整,暂不支持这个功能

展开
收起
游客sskepztn5q2uq 2024-07-26 08:26:20 91 0
1 条回答
写回答
取消 提交回答
  • 采纳回答

    客户端实现根本就不完整,
    ClientImpl#compositedMessageInterceptor不对外开放,消息拦截需要改源码或者通过反射给客户端增加自定义的拦截器才行,真阿里开源

    2024-07-26 10:44:07
    赞同 12 展开评论 打赏

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

相关产品

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

    更多
    RocketMQ Client-GO 介绍 立即下载
    RocketMQ Prometheus Exporter 打造定制化 DevOps 平台 立即下载
    基于 RocketMQ Prometheus Exporter 打造定制化 DevOps 平台 立即下载