From e4b37f33de8b8f344c28b6c011eb31150b3c028d Mon Sep 17 00:00:00 2001
From: mcy <rewerma@163.com>
Date: Thu, 11 Jul 2019 20:44:39 +0800
Subject: [PATCH] modify

---
 deployer/src/main/resources/canal.properties | 10 ++++------
 1 file changed, 4 insertions(+), 6 deletions(-)

diff --git a/deployer/src/main/resources/canal.properties b/deployer/src/main/resources/canal.properties
index e01b8028..580c1ba8 100644
--- a/deployer/src/main/resources/canal.properties
+++ b/deployer/src/main/resources/canal.properties
@@ -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"
\ No newline at end of file
+canal.mq.kafka.kerberos.jaasFilePath = "../conf/kerberos/jaas.conf"