[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