From b153e61f0dd52fd17b62e5be3d8816cb85243970 Mon Sep 17 00:00:00 2001 From: elegance code Date: Fri, 16 May 2025 15:03:01 +0800 Subject: [PATCH] fix issue #5401 (#5402) --- .../connector/rocketmq/producer/CanalRocketMQProducer.java | 4 ++++ 1 file changed, 4 insertions(+) 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 {