单机版本canal需要修改的内容:vim canal.propertiescanal.destinations examplecanal.serverMode kafkacanal.instance.filter.query.dml truecanal.auto.scan truekafka.bootstrap.servers xxx:9092,kafka.sasl.jaas.config org.apache.kafka.common.security.plain.PlainLoginModule required usernamexxx passwordxxx;kafka.sasl.mechanism PLAINkafka.security.protocol SASL_PLAINTEXT#或者:sasl.jaas.configorg.apache.kafka.common.security.scram.ScramLoginModule required usernamexxx passwordxxx;security.protocolSASL_PLAINTEXTsasl.mechanismSCRAM-SHA-512example 目录下修改:instance.propertiescanal.instance.mysql.slaveId139canal.instance.gtidontruecanal.instance.master.address192.168.3.3:3305canal.instance.master.journal.namecanal.instance.master.positioncanal.instance.master.timestampcanal.instance.master.gtidcanal.instance.rds.accesskeycanal.instance.rds.secretkeycanal.instance.rds.instanceIdcanal.instance.tsdb.enabletruecanal.instance.dbUsernamecanalcanal.instance.dbPasswordcanalcanal.instance.connectionCharset UTF-8canal.instance.enableDruidfalsecanal.instance.filter.regexdb_mdb_iot.*\\..*canal.mq.topiccanal_iot_topiccanal.mq.dynamicTopiccanal_iot_topic_batch:db_mdb_iot.*\\.table2,canal_iot_topic_batch:db_mdb_iot.*\\.table3,canal_iot_topic_batch:db_mdb_iot.*\\.table4canal.mq.partition0#注意是这几个。canal.instance.mysql.slaveId139canal.instance.gtidontruecanal.instance.master.address192.168.3.1:3309canal.instance.filter.regexdb_mdb_iot.*\\..*canal.mq.topiccanal_iot_topiccanal.mq.dynamicTopiccanal_iot_topic_batch:db_mdb_iot.*\\.table2,canal_iot_topic_batch:db_mdb_iot.*\\.table1,canal_iot_topic_batch:db_mdb_iot.*\\.table3,canal_iot_topic_batch:db_mdb_iot.*\\.t_iot_task_objectcanal.mq.partition0
canal单机部署注意事项
单机版本canal需要修改的内容:vim canal.propertiescanal.destinations examplecanal.serverMode kafkacanal.instance.filter.query.dml truecanal.auto.scan truekafka.bootstrap.servers xxx:9092,kafka.sasl.jaas.config org.apache.kafka.common.security.plain.PlainLoginModule required usernamexxx passwordxxx;kafka.sasl.mechanism PLAINkafka.security.protocol SASL_PLAINTEXT#或者:sasl.jaas.configorg.apache.kafka.common.security.scram.ScramLoginModule required usernamexxx passwordxxx;security.protocolSASL_PLAINTEXTsasl.mechanismSCRAM-SHA-512example 目录下修改:instance.propertiescanal.instance.mysql.slaveId139canal.instance.gtidontruecanal.instance.master.address192.168.3.3:3305canal.instance.master.journal.namecanal.instance.master.positioncanal.instance.master.timestampcanal.instance.master.gtidcanal.instance.rds.accesskeycanal.instance.rds.secretkeycanal.instance.rds.instanceIdcanal.instance.tsdb.enabletruecanal.instance.dbUsernamecanalcanal.instance.dbPasswordcanalcanal.instance.connectionCharset UTF-8canal.instance.enableDruidfalsecanal.instance.filter.regexdb_mdb_iot.*\\..*canal.mq.topiccanal_iot_topiccanal.mq.dynamicTopiccanal_iot_topic_batch:db_mdb_iot.*\\.table2,canal_iot_topic_batch:db_mdb_iot.*\\.table3,canal_iot_topic_batch:db_mdb_iot.*\\.table4canal.mq.partition0#注意是这几个。canal.instance.mysql.slaveId139canal.instance.gtidontruecanal.instance.master.address192.168.3.1:3309canal.instance.filter.regexdb_mdb_iot.*\\..*canal.mq.topiccanal_iot_topiccanal.mq.dynamicTopiccanal_iot_topic_batch:db_mdb_iot.*\\.table2,canal_iot_topic_batch:db_mdb_iot.*\\.table1,canal_iot_topic_batch:db_mdb_iot.*\\.table3,canal_iot_topic_batch:db_mdb_iot.*\\.t_iot_task_objectcanal.mq.partition0