From 91bddfeed6f250460238027e5a2eb3191bd6f87d Mon Sep 17 00:00:00 2001 From: Treeyh Date: Fri, 16 Apr 2021 22:08:28 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E6=8E=A5=E5=85=A5=E9=98=BF?= =?UTF-8?q?=E9=87=8C=E4=BA=91RocketMq=20no=20route=20info=20for=20this=20t?= =?UTF-8?q?opic=20=E9=97=AE=E9=A2=98=20(#3220)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Co-authored-by: hai.yu --- .../otter/canal/connector/core/producer/AbstractMQProducer.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/connector/core/src/main/java/com/alibaba/otter/canal/connector/core/producer/AbstractMQProducer.java b/connector/core/src/main/java/com/alibaba/otter/canal/connector/core/producer/AbstractMQProducer.java index a1bd0d42..89761cc4 100644 --- a/connector/core/src/main/java/com/alibaba/otter/canal/connector/core/producer/AbstractMQProducer.java +++ b/connector/core/src/main/java/com/alibaba/otter/canal/connector/core/producer/AbstractMQProducer.java @@ -120,7 +120,7 @@ public abstract class AbstractMQProducer implements CanalMQProducer { } String aliyunSecretKey = PropertiesUtils.getProperty(properties, CanalConstants.CANAL_ALIYUN_SECRET_KEY); if (!StringUtils.isEmpty(aliyunSecretKey)) { - mqProperties.setAliyunAccessKey(aliyunSecretKey); + mqProperties.setAliyunSecretKey(aliyunSecretKey); } String aliyunUid = PropertiesUtils.getProperty(properties, CanalConstants.CANAL_ALIYUN_UID); if (!StringUtils.isEmpty(aliyunUid)) {