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; } }