|
|
@@ -13,7 +13,7 @@ canal.zkServers =
|
|
|
canal.zookeeper.flush.period = 1000
|
|
|
canal.withoutNetty = false
|
|
|
# tcp, kafka, RocketMQ
|
|
|
-canal.serverMode = kafka
|
|
|
+canal.serverMode = tcp
|
|
|
# flush meta cursor/parse position to file
|
|
|
canal.file.data.dir = ${canal.conf.dir}
|
|
|
canal.file.flush.period = 1000
|
|
|
@@ -67,7 +67,7 @@ canal.instance.parser.parallel = true
|
|
|
canal.instance.parser.parallelBufferSize = 256
|
|
|
|
|
|
# table meta tsdb info
|
|
|
-canal.instance.tsdb.enable = false
|
|
|
+canal.instance.tsdb.enable = true
|
|
|
canal.instance.tsdb.dir = ${canal.file.data.dir:../conf}/${canal.instance.destination:}
|
|
|
canal.instance.tsdb.url = jdbc:h2:${canal.instance.tsdb.dir}/h2;CACHE_SIZE=1000;MODE=MYSQL;
|
|
|
canal.instance.tsdb.dbUsername = canal
|
|
|
@@ -104,7 +104,7 @@ canal.instance.global.spring.xml = classpath:spring/file-instance.xml
|
|
|
##################################################
|
|
|
######### MQ #############
|
|
|
##################################################
|
|
|
-canal.mq.servers = 127.0.0.1:9092
|
|
|
+canal.mq.servers = 127.0.0.1:6667
|
|
|
canal.mq.retries = 0
|
|
|
canal.mq.batchSize = 16384
|
|
|
canal.mq.maxRequestSize = 1048576
|
|
|
@@ -115,8 +115,6 @@ canal.mq.canalGetTimeout = 100
|
|
|
canal.mq.flatMessage = true
|
|
|
canal.mq.compressionType = none
|
|
|
canal.mq.acks = all
|
|
|
-# use transaction for kafka flatMessage batch produce
|
|
|
-canal.mq.transaction = true
|
|
|
#canal.mq.properties. =
|
|
|
canal.mq.producerGroup = test
|
|
|
# Set this value to "cloud", if you want open message trace feature in aliyun.
|
|
|
@@ -129,4 +127,4 @@ canal.mq.accessChannel = local
|
|
|
##################################################
|
|
|
canal.mq.kafka.kerberos.enable = false
|
|
|
canal.mq.kafka.kerberos.krb5FilePath = "../conf/kerberos/krb5.conf"
|
|
|
-canal.mq.kafka.kerberos.jaasFilePath = "../conf/kerberos/jaas.conf"
|
|
|
+canal.mq.kafka.kerberos.jaasFilePath = "../conf/kerberos/jaas.conf"
|
mcy