dinglei

[ISSUE #4584] Add new persist method to update consume offset to remote server.

2

**Make sure set the target branch to `develop`** ## What is the purpose of the change close #4584 ## Brief changelog Add new persist method to update consume offset to...

Make sure the list of message queues is not null before using selecting a queue. in orderly message sending example.

7

in example/ordermessage/producer.java. make sure message queue is not null before using selecting a queue. ``` SendResult sendResult = producer.send(msg, new MessageQueueSelector() { @Override public MessageQueue select(List mqs, Message msg, Object...

Update readme file according to the new features in the latest release version.

Are you using RocketMQ Go SDK?

16

## Due Diligence It is well known that we are attaching great importance to the multi-language clients of the RocketMQ. We have released several versions, and continue to optimize them....

Support the dynamic closing of track message sending on the client.

1

可靠性和可用性是每个 MQ 系统最重要的两个特性，通过Message Track Trace我们应该查看完整的消息链接，快速找到进程消息传递失败的根本原因，并且可以查询到很多参数值，例如发送成本时间、消费成本时间、存储在 broker 中的时间等等，当服务端压力过大或者存储紧张的时候，我们可以通过命令临时关闭轨迹消息进行降级。Apache RocketMQ在RIP-6中已经实现了消息轨迹的功能，针对CPP客户端，基本的轨迹功能已经实现，需要进一步实现临时降级策略。本题目的目的就是要在CPP客户端实现轨迹降级策略，主要包括： 1.学习Apache RocketMQ知识，详细了解RocketMQ原理、使用方式 2.掌握Apache RocketMQ中轨迹消息特性原理和代码 3.在社区中提交Issue，完成相关代码，review后被社区合并 相关材料： https://github.com/apache/rocketmq-client-cpp https://github.com/apache/rocketmq/wiki/RIP-6-Message-Trace https://github.com/apache/rocketmq/blob/develop/docs/cn/msg_trace/user_guide.md https://rocketmq.apache.org/

Are you using RocketMQ c++ sdk?

7

## Due Diligence It is well known that the multi-language clients of the RocketMQ community (with the exception of Java) are built around the c++ kernel. We have always attached...

[Master] Try to support message trace.

2

the CPP core will support message trace since 2.1.0, it is better to add a swift to open the message trace.

Are you using RocketMQ python sdk?

3

## Due Diligence It is well known that we are attaching great importance to the multi-language clients of the RocketMQ. We have released several versions, and continue to optimize them....

Use litePullConsumer model instead of default pull consumer.

3

See description in RocketMQ, ``` /** * @deprecated * Default pulling consumer. * This class will be removed in 2022, and a better implementation {@link DefaultLitePullConsumer} is recommend to use...

Do not throw exception in order producer demo.

6

UnsupportedEncodingException should not be throw out in main function. ``` public static void main(String[] args) throws UnsupportedEncodingException ``` https://github.com/apache/rocketmq/blob/develop/example/src/main/java/org/apache/rocketmq/example/ordermessage/Producer.java