Mysql通过Canal同步Elasticsearch( 二 ) _生活百科

文章插图

文章插图
重启，可以清一下浏览器缓存
exitdocker restart elasticsearch-head安装 Canal可以参考：
https://blog.csdn.net/qq_32836247/article/details/116561732

2 G的服务器搞不来

安装镜像

# 拉取镜像$ docker pull canal/canal-server:v1.1.5# 随便启动一个，用于拉取配置文件$ docker run --name canal -p 11111:11111-d canal/canal-server:v1.1.5# 挂载配置文件$ docker cp canal:/home/admin /home/haha/docker-canal# 删除容器$ docker stop canal$ docker rm canal# 启动新的容器$ docker run --name canal -p 11111:11111 -v /home/haha/docker-canal:/home/admin -d canal/canal-server:v1.1.5

编写配置文件

# 切换到挂载目录$ cd /usr/kang/docker-canal# 切换到需要修改的配置文件所在目录$ cd canal-server/conf/example/# 修改文件$ vim instance.properties

更改 slaveId=10，记得和数据库的 server-id 不一样
更改数据库地址
【Mysql通过Canal同步Elasticsearch】

canal.instance.mysql.slaveId=0canal.instance.master.address=192.168.80.80:3306canal.instance.dbUsername=rootcanal.instance.dbPassword=123456789

文章插图

################################################### mysql serverId , v1.0.26+ will autoGen# canal.instance.mysql.slaveId=0# enable gtid use true/falsecanal.instance.gtidon=false# position info# 数据库地址canal.instance.master.address=192.168.118.130:3306# 当前正在写入的 binlog文件，第二部分中mysql命令可查询canal.instance.master.journal.name=binlog.000001# 正在写入的偏移量canal.instance.master.position=156canal.instance.master.timestamp=canal.instance.master.gtid=# rds oss binlogcanal.instance.rds.secretkey=canal.instance.rds.instanceId=# table meta tsdb infocanal.instance.tsdb.enable=true#canal.instance.tsdb.url=jdbc:mysql://127.0.0.1:3306/canal_tsdb#canal.instance.tsdb.dbUsername=canal#canal.instance.tsdb.dbPassword=canal#canal.instance.standby.address =#canal.instance.standby.journal.name =#canal.instance.standby.position =#canal.instance.standby.timestamp =#canal.instance.standby.gtid=# username/password# mysql 用户，若之前创建过可不用修改canal.instance.dbUsername=canalcanal.instance.dbPassword=canalcanal.instance.connectionCharset = UTF-8# enable druid Decrypt database passwordcanal.instance.enableDruid=false#canal.instance.pwdPublicKey=MFwwDQYJKoZIhvcNAQEBBQADSwAwSAJBALK4BUxdDltRRE5/zXpVEVPUgunvscYFtEip3pmLlhrWpacX7y7GCMo2/JM6LeHmiiNdH1FWgGCpUfircSwlWKUCAwEAAQ==# table regexcanal.instance.filter.regex=.*\\..*# table black regexcanal.instance.filter.black.regex=mysql\\.slave_.*# table field filter(format: schema1.tableName1:field1/field2,schema2.tableName2:field1/field2)#canal.instance.filter.field=test1.t_product:id/subject/keywords,test2.t_company:id/name/contact/ch# table field black filter(format: schema1.tableName1:field1/field2,schema2.tableName2:field1/field2)#canal.instance.filter.black.field=test1.t_product:subject/product_image,test2.t_company:id/name/contact/ch# mq configcanal.mq.topic=example# dynamic topic route by schema or table regex#canal.mq.dynamicTopic=mytest1.user,mytest2\\..*,.*\\..*canal.mq.partition=0# hash partition config#canal.mq.partitionsNum=3#canal.mq.partitionHash=test.table:id^name,.*\\..*#canal.mq.dynamicTopicPartitionNum=test.*:4,mycanal:6#################################################