Merge pull request #698 from RongtongJin/dev-1216

Upgrade rocketmq client version to 5.3.1

Author: panzhi33

rocketmq-spring-boot-parent/pom.xml

@@ -42,7 +42,7 @@
 
         <rocketmq.spring.boot.version>2.3.2-SNAPSHOT</rocketmq.spring.boot.version>
 
-        <rocketmq.version>5.3.0</rocketmq.version>
+        <rocketmq.version>5.3.1</rocketmq.version>
         <slf4j.version>1.7.25</slf4j.version>
         <jackson.version>2.11.1</jackson.version>
         <fastjson.version>1.2.83</fastjson.version>

rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/support/RocketMQUtil.java

@@ -269,7 +269,7 @@ public static DefaultMQProducer createDefaultMQProducer(String groupName, String
 
         if (isEnableMsgTrace) {
             try {
-                AsyncTraceDispatcher dispatcher = new AsyncTraceDispatcher(groupName, TraceDispatcher.Type.PRODUCE, customizedTraceTopic, isEnableAcl ? new AclClientRPCHook(new SessionCredentials(ak, sk)) : null);
+                AsyncTraceDispatcher dispatcher = new AsyncTraceDispatcher(groupName, TraceDispatcher.Type.PRODUCE, 10, customizedTraceTopic, isEnableAcl ? new AclClientRPCHook(new SessionCredentials(ak, sk)) : null);
                 dispatcher.setHostProducer(producer.getDefaultMQProducerImpl());
                 Field field = DefaultMQProducer.class.getDeclaredField("traceDispatcher");
                 field.setAccessible(true);
@@ -285,9 +285,9 @@ public static DefaultMQProducer createDefaultMQProducer(String groupName, String
     }
 
     public static DefaultLitePullConsumer createDefaultLitePullConsumer(String nameServer, String accessChannel,
-            String groupName, String topicName, MessageModel messageModel, SelectorType selectorType,
-            String selectorExpression, String ak, String sk, int pullBatchSize, boolean useTLS)
-            throws MQClientException {
+        String groupName, String topicName, MessageModel messageModel, SelectorType selectorType,
+        String selectorExpression, String ak, String sk, int pullBatchSize, boolean useTLS)
+        throws MQClientException {
         DefaultLitePullConsumer litePullConsumer = null;
         if (StringUtils.hasLength(ak) && StringUtils.hasLength(sk)) {
             litePullConsumer = new DefaultLitePullConsumer(groupName, new AclClientRPCHook(new SessionCredentials(ak, sk)));