database_sync/config-old-new.ini

[canal]
# MySQL host
host = 210.16.186.252
; 210.16.186.252
; root    kptzhu@163.com
# MySQL port
port = 3326
# MySQL user, must have replication privilege
user = root
# MySQL password
password = root
# Flavor: mysql or mariadb
flavor = mariadb
# Unique Server ID
serverID = 101
# mysqldump execution path
mysqldump = mysqldump
# dump databases, seperated by comma
dbs = test
# dump tables, seperated by comma, will overwrite dbs templetdry
tables = barfeedremain,barmilk,downloadedplan,downloadplandtl1,downloadplandtl1_exec,downloadplandtl2,recweight
# barfeedremain,barmilk,templetdry,downloadedplan,downloadplandtl1,downloadplandtl1_exec,downloadplandtl2,recweight
# database for dump tables, seperated by comma, will overwrite dbs
tableDB = test
# ignore tables, must be database.table format, separated by comma
ignoreTables = 
# start sync from binlog name
startName = 
# start sync from binlog position of
startPos = 
# master heartbeat period(*time.Second)
heartbeatPeriod = 60
# connection read timeout(*time.Second)
readTimeout = 90
# nodename  key name intpastureid
nodename = 
# nodevalue value
nodevalue = 
# showlog
showlog = 0
onetimerows = 500

[kafka]
# enable kafka
kafkaEnable = false
Offset = 
kafka_host = www.kptyun.com
kafka_port = 9092
kafka_topic = tmrwatch_uploaddata_
saslEnable = false
username = root
saslpassword = root
tlsEnable = false
clientcert = 
clientkey = 
cacert = 

[mqtt]
# enable kafka
mqttEnable = true
topic = NX-PRD-WiseFarm-KBTTMR-Up
qos = 1
CleanSession = true
# host = 218.241.17.66
# port = 1983
# path = 
host = ajtk7v5ybo99i-ats.iot.cn-northwest-1.amazonaws.com.cn
port = 8883
path = /NX-PRD-WiseFarm-KBTTMR-Up
#host = auuhfh5e8d294-ats.iot.us-east-2.amazonaws.com
#port = 8883
#path = /MyIotThing
saslEnable = true
username = kptmqtt
saslpassword = kepaiteng
tlsEnable = false
# clientcert = pem/bbbc7ee0f6-certificate.pem.crt
# clientkey = pem/bbbc7ee0f6-private.pem.key

clientcert = pem/158d083e6c-certificate.pem.crt
clientkey = pem/158d083e6c-private.pem.key

cacert = 
old = true

[Service]
ServiceName = KPTCanalService
ServiceDisplayName = KPTCanalService
ServiceDescription = 科湃腾数据同步服务






[barmilk]
## 字段名称修改
feedpbname = barname
## 新增字段赋值
pastureid = 1

[downloadedplan]
## 实际重量
ActualWeight = iweight 
pastureid = 1  
## 同步时需要删除的字段
deleteField = TodayID,Minutes,MobileMacNo,ButtonSucc,DriverID,driverdname,beginTime,FWEIGHR,CCountRatioRtime


[downloadplandtl1]
## 字段名称修改
Dry = dryfeed
## 新增字段赋值
pastureid = 1
date = now()
## 同步时需要删除的字段
deleteField = FPointID,NextOpId,LastOpId,UPrice



[downloadplandtl1_exec]
## 新增字段赋值
pastureid = 1  
date = now()
## 同步时需要删除的字段
deleteField = Fid,NextOpId,LastOpId,Changebyman,feedsort


[downloadplandtl2]
feedpallowratio = allowratio
## 新增字段赋值
pastureid = 1  
date = now()
deleteField = NextOpId,LastOpID,changebyman


[recweight]
pastureid = 1