diff --git a/connector/rocketmq-connector/src/main/java/com/alibaba/otter/canal/connector/rocketmq/producer/CanalRocketMQProducer.java b/connector/rocketmq-connector/src/main/java/com/alibaba/otter/canal/connector/rocketmq/producer/CanalRocketMQProducer.java index 2f174557..eb478c95 100644 --- a/connector/rocketmq-connector/src/main/java/com/alibaba/otter/canal/connector/rocketmq/producer/CanalRocketMQProducer.java +++ b/connector/rocketmq-connector/src/main/java/com/alibaba/otter/canal/connector/rocketmq/producer/CanalRocketMQProducer.java @@ -372,6 +372,10 @@ public class CanalRocketMQProducer extends AbstractMQProducer implements CanalMQ topicName = this.defaultMQProducer.withNamespace(topicName); DefaultMQProducerImpl innerProducer = this.defaultMQProducer.getDefaultMQProducerImpl(); TopicPublishInfo topicInfo = innerProducer.getTopicPublishInfoTable().get(topicName); + if (topicInfo == null) { + innerProducer.getMqClientFactory().updateTopicRouteInfoFromNameServer(topicName); + } + topicInfo = innerProducer.getTopicPublishInfoTable().get(topicName); if (topicInfo == null) { return null; } else {