[canal] # MySQL host host = 127.0.0.1 # MySQL port port = 3309 # MySQL user, must have replication privilege user = root # MySQL password password = 123456 # Flavor: mysql or mariadb flavor = mariadb # Unique Server ID serverID = 101 # mysqldump execution path mysqldump = mysqldump # dump databases, seperated by comma # dbs = tmrwatch # dump tables, seperated by comma, will overwrite dbs templetdry tables = barfeedremain,barmilk,downloadedplan,downloadplandtl1,downloadplandtl1_exec,downloadplandtl2,recweight ; 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 = tmrwatch # 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 = pasturecode # nodevalue value nodevalue = 111 # showlog showlog = 0 onetimerows = 50 [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 = TMR_TEST_03_20 qos = 1 CleanSession = true host = 218.241.17.66 port = 1983 path = #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 cacert = old = false [Service] ServiceName = KPTCanalService ServiceDisplayName = KPTCanalService ServiceDescription = 科湃腾数据同步服务1 [barfeedremain] barname = ztFeedpName deleteField = pastureid,operatetime,emp,pid,times [barmilk] barname = feedpbname deleteField = pastureid,avgmonthage,bw,dayw,fetal,dayspre,pro,lactose,tem,cowsum,cowclass,cowclassid,bigcowclass,emp [downloadedplan] deleteField = pastureid,plantime,outitems,ptstempid,ptstempletname,thoweight,fpweight,lweight,iweight,oweight,tversion,ptversion,enable,isUse,completedtime [downloadplandtl1] flpid = FPointID dryfeed = Dry pricefeed = UPrice deleteField = pastureid,begintime,optdevice,outweight,type,date [downloadplandtl1_exec] deleteField= pastureid,flpid,begintime,optdevice,type,date [downloadplandtl2] allowratio = feedpallowratio deleteField = pastureid,type,lweighthis,remainleftw,allowrw,begintime,begintag,endtag,optdevice,bigcowname,priceweight,fpid,useinbartype,date [recweight] deleteField = pastureid