生产者

canal_consumer服务

通过截取[[MySQL]]的[[binlog]]日志，以监测数据库表中的字段变化。当字段变化，则会生产一条mq消息。

Topic

消费者

整体架构 mysql->canal->canal-conumser->rocketmq->消费者