diff --git a/spring-cloud-stream-binder-rocketmq/src/main/java/org/springframework/cloud/stream/binder/rocketmq/config/RocketMQComponent4BinderAutoConfiguration.java b/spring-cloud-stream-binder-rocketmq/src/main/java/org/springframework/cloud/stream/binder/rocketmq/config/RocketMQComponent4BinderAutoConfiguration.java index e481ac87..401d5703 100644 --- a/spring-cloud-stream-binder-rocketmq/src/main/java/org/springframework/cloud/stream/binder/rocketmq/config/RocketMQComponent4BinderAutoConfiguration.java +++ b/spring-cloud-stream-binder-rocketmq/src/main/java/org/springframework/cloud/stream/binder/rocketmq/config/RocketMQComponent4BinderAutoConfiguration.java @@ -67,6 +67,9 @@ public class RocketMQComponent4BinderAutoConfiguration { else { producer = new DefaultMQProducer(RocketMQBinderConstants.DEFAULT_GROUP); } + if(StringUtils.isEmpty(configNameServer)) { + configNameServer = RocketMQBinderConstants.DEFAULT_NAME_SERVER; + } producer.setNamesrvAddr(configNameServer); return producer; }