依赖如下
<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;
我想请问下在当前版本下如何开启消息轨迹呢?还是说当前版本特性并未迭代完整,暂不支持这个功能
客户端实现根本就不完整,
ClientImpl#compositedMessageInterceptor不对外开放,消息拦截需要改源码或者通过反射给客户端增加自定义的拦截器才行,真阿里开源
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
涵盖 RocketMQ、Kafka、RabbitMQ、MQTT、轻量消息队列(原MNS) 的消息队列产品体系,全系产品 Serverless 化。RocketMQ 一站式学习:https://rocketmq.io/