Skip to content

Commit 0761bf9

Browse files
committed
topic not required
1 parent bb4bc5c commit 0761bf9

1 file changed

Lines changed: 6 additions & 3 deletions

File tree

rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/autoconfigure/ExtTemplateResetConfiguration.java

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -114,9 +114,12 @@ private ProducerBuilder createProducer(ExtProducerResetConfiguration annotation)
114114
ClientConfiguration clientConfiguration = RocketMQUtil.createClientConfiguration(accessKey, secretKey,
115115
endpoints, Duration.ofSeconds(requestTimeout), sslEnabled, namespace);
116116
final ClientServiceProvider provider = ClientServiceProvider.loadService();
117-
return provider.newProducerBuilder()
118-
.setClientConfiguration(clientConfiguration).setMaxAttempts(annotation.maxAttempts())
119-
.setTopics(topic.split(RocketMQAutoConfiguration.COMMA));
117+
ProducerBuilder producerBuilder = provider.newProducerBuilder()
118+
.setClientConfiguration(clientConfiguration).setMaxAttempts(annotation.maxAttempts());
119+
if (StringUtils.hasLength(topic)) {
120+
producerBuilder.setTopics(topic.split(RocketMQAutoConfiguration.COMMA));
121+
}
122+
return producerBuilder;
120123
}
121124

122125
}

0 commit comments

Comments
 (0)