Browse Source

修复接入阿里云RocketMq no route info for this topic 问题 (#3220)

Co-authored-by: hai.yu <hai.yu@snowballtech.com>
Treeyh 4 years ago
parent
commit
91bddfeed6

+ 1 - 1
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)) {