Browse Source

配置中增加 canal.mq.acks canal.mq.compressionType

mcy 6 years ago
parent
commit
c376f0afd2
1 changed files with 3 additions and 1 deletions
  1. 3 1
      deployer/src/main/resources/canal.properties

+ 3 - 1
deployer/src/main/resources/canal.properties

@@ -108,4 +108,6 @@ canal.mq.lingerMs=1
 canal.mq.bufferMemory=33554432
 canal.mq.canalBatchSize=50
 canal.mq.canalGetTimeout=100
-canal.mq.flatMessage=true
+canal.mq.flatMessage=true
+#canal.mq.compressionType=none
+#canal.mq.acks=all