From 0761bf9b64bf2fae76412e255d248e887c79460b Mon Sep 17 00:00:00 2001 From: panzhi33 Date: Mon, 1 Dec 2025 21:09:58 +0800 Subject: [PATCH] topic not required --- .../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 ba8021e4..905a08d5 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 @@ private ProducerBuilder createProducer(ExtProducerResetConfiguration annotation) 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; } }