安装canal并监听mysql数据变更,并使用kafDrop查看消息

76 ·
0 ·
21天前
最新一次编辑的原因:

拉取canal镜像

docker pull canal/canal-server:latest

运行canal服务

docker run -d --name canal-server -p 3307:3307canal/canal-server

配置mysql

检查是否都开启了

配置canal

vi canal-server/conf/example/instance.properties
#################################################
## mysql serverId , v1.0.26+ will autoGen
canal.instance.mysql.slaveId=1
# enable gtid use true/false
canal.instance.gtidon=false
# position info
canal.instance.master.address=172.28.36.18:3306
canal.instance.master.journal.name=
canal.instance.master.position=
canal.instance.master.timestamp=
canal.instance.master.gtid=

# table regex
# canal.instance.filter.regex=.*\\..*
canal.instance.filter.regex=erp_order.virtual_order,erp_order.order,erp_order.virtual_order_shipping_address,erp_order.v
irtual_order_line_item,erp_order.virtual_order_operation_log,erp_order.order_after_sale,erp_basic_data.channel,erp_shipp
ing.tracking_number,udesk.test


# mq config
canal.mq.topic=basic-canal-server-erp-data
# 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

 

使用上一个镜像,然后开放端口
 docker run --name canalServer -p 9100:9100 -p 11110:11110 -p 11112:11112 -p 11111:11111 canal:tag

 

 

安装kafdrop查看kafka里面的消息

https://hub.docker.com/r/obsidiandynamics/kafdrop

docker pull obsidiandynamics/kafdrop

启动kafDrop

docker run --name kafkaView -d -p 9000:9000 -e KAFKA_BROKERCONNECT=172.28.36.18:9092 -e JVM_OPTS="-Xms32M -Xmx64M"  -e SERVER_SERVLET_CONTEXTPATH="/"  obsidiandynamics/kafdrop

--rm 该参数表名当应用停止时是自动删除,在上面的命令中不加 -rm 运行过得程序停止后就能保存下来

访问地址 http://localhost:9000/ 就能看到kafka内部的消息了

 

 

 


本作品系原创,采用《署名-非商业性使用-禁止演绎4.0 国际》许可协议.转载请说明出处
本文链接:https://www.upupor.com/u/21082809320178246656 复制

无评论内容,快来评论吧