|
@@ -78,8 +78,8 @@ canal.instance.tsdb.snapshot.interval = 24
|
|
|
canal.instance.tsdb.snapshot.expire = 360
|
|
|
|
|
|
# aliyun ak/sk , support rds/mq
|
|
|
-canal.aliyun.accesskey =
|
|
|
-canal.aliyun.secretkey =
|
|
|
+canal.aliyun.accessKey =
|
|
|
+canal.aliyun.secretKey =
|
|
|
|
|
|
#################################################
|
|
|
######### destinations #############
|
|
@@ -117,4 +117,4 @@ canal.mq.compressionType = none
|
|
|
canal.mq.acks = all
|
|
|
# use transaction for kafka flatMessage batch produce
|
|
|
canal.mq.transaction = false
|
|
|
-#canal.mq.properties. =
|
|
|
+#canal.mq.properties. =
|