Skip to content

Commit a37c820

Browse files
authored
fix issue alibaba#5401
1 parent c998b3f commit a37c820

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

connector/rocketmq-connector/src/main/java/com/alibaba/otter/canal/connector/rocketmq/producer/CanalRocketMQProducer.java

+3
Original file line numberDiff line numberDiff line change
@@ -372,6 +372,9 @@ private Integer getTopicDynamicQueuesSize(Boolean enable, String topicName) {
372372
topicName = this.defaultMQProducer.withNamespace(topicName);
373373
DefaultMQProducerImpl innerProducer = this.defaultMQProducer.getDefaultMQProducerImpl();
374374
TopicPublishInfo topicInfo = innerProducer.getTopicPublishInfoTable().get(topicName);
375+
if (topicInfo == null) {
376+
innerProducer.getMqClientFactory().updateTopicRouteInfoFromNameServer(topicName);
377+
}
375378
if (topicInfo == null) {
376379
return null;
377380
} else {

0 commit comments

Comments
 (0)