(rocketmq-spring) branch master updated: Topic not required (#753)

[jinrongtong]

This is an automated email from the ASF dual-hosted git repository.

jinrongtong pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-spring.git


The following commit(s) were added to refs/heads/master by this push:
     new cbacbd6  Topic not required (#753)
cbacbd6 is described below

commit cbacbd625d9c0da263496abf14cbd89a37a1d9ad
Author: panzhi <panzh...@qq.com>
AuthorDate: Tue Dec 2 11:51:04 2025 +0800

    Topic not required (#753)
---
 .../client/autoconfigure/ExtTemplateResetConfiguration.java      | 9 ++++++---
 1 file changed, 6 insertions(+), 3 deletions(-)

diff --git 
a/rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/autoconfigure/ExtTemplateResetConfiguration.java
 
b/rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/autoconfigure/ExtTemplateResetConfiguration.java
index ba8021e..905a08d 100644
--- 
a/rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/autoconfigure/ExtTemplateResetConfiguration.java
+++ 
b/rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/autoconfigure/ExtTemplateResetConfiguration.java
@@ -114,9 +114,12 @@ public class ExtTemplateResetConfiguration implements 
ApplicationContextAware, S
         ClientConfiguration clientConfiguration = 
RocketMQUtil.createClientConfiguration(accessKey, secretKey,
             endpoints, Duration.ofSeconds(requestTimeout), sslEnabled, 
namespace);
         final ClientServiceProvider provider = 
ClientServiceProvider.loadService();
-        return provider.newProducerBuilder()
-                
.setClientConfiguration(clientConfiguration).setMaxAttempts(annotation.maxAttempts())
-                .setTopics(topic.split(RocketMQAutoConfiguration.COMMA));
+        ProducerBuilder producerBuilder = provider.newProducerBuilder()
+                
.setClientConfiguration(clientConfiguration).setMaxAttempts(annotation.maxAttempts());
+        if (StringUtils.hasLength(topic)) {
+            
producerBuilder.setTopics(topic.split(RocketMQAutoConfiguration.COMMA));
+        }
+        return producerBuilder;
     }
 
 }