[canal] # MySQL host host = 127.0.0.1 # 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 tables, seperated by comma, will overwrite dbs tables = ftdetaildate,feedtemplet,feed,barfeedremain,barmilk,downloadedplan,downloadplandtl1,downloadplandtl1_exec,downloadplandtl2 # ,recweight # database for dump tables, seperated by comma, will overwrite dbs tableDB = tmrwatch2 # 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 =lymy_xz # showlog showlog = 0 onetimerows = 100 [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/LYMY/kptmqtt/lymy_xz/xz qos = 1 CleanSession = true #默认用这个 host =mq.heatwatch.cn port = 1983 path = #新希望用这个 #host = auuhfh5e8d294-ats.iot.us-east-2.amazonaws.com #port = 8883 #path = /MyIotThing #使用kafka时这里设置true 否则 false saslEnable = true username = kptmqtt saslpassword = kepaiteng #使用mqtt时这里设置true 否则 false tlsEnable = false clientcert = pem/bbbc7ee0f6-certificate.pem.crt clientkey = pem/bbbc7ee0f6-private.pem.key cacert = [Service] ServiceName = KPTCanalService ServiceDisplayName = KPTCanalService ServiceDescription = 科湃腾数据同步服务 [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,date [downloadplandtl1_exec] deleteField= pastureid,flpid,begintime,optdevice,date,surplus [downloadplandtl2] allowratio = feedpallowratio deleteField = pastureid,lweighthis,remainleftw,allowrw,begintime,begintag,endtag,optdevice,bigcowname,priceweight,fpid,useinbartype,date [recweight] deleteField = pastureid [feedtemplet] deleteField = issueversion,issueid,backup1,backup2,cattle,volume,is_modify,group_data_id,group_version,autozone,surplus [feed] deleteField = is_surplus