日志记录服务

# 配置
[mysqld]
# 配置 ServerID
server_id=1
# 开启 binlog
log-bin=binlog
# 选择 ROW 模式
binlog-format=ROW

# 查询
show variables like '%log_bin%'

# 授权
CREATE USER canal IDENTIFIED BY 'canal';
GRANT SELECT, REPLICATION SLAVE, REPLICATION CLIENT ON *.* TO 'canal'@'%';
# 如果权限问题登陆不了使用下面授权语句
-- GRANT ALL PRIVILEGES ON *.* TO 'canal'@'%';
FLUSH PRIVILEGES;

# 配置数据连接（instance.properties）：example -> muses
canal.instance.mysql.slaveId=2
canal.instance.master.address=127.0.0.1:3306
canal.instance.dbUsername=canal
canal.instance.dbPassword=canal
# 过滤表名
canal.instance.filter.regex=muses\\.t_.*
canal.mq.topic=log-topic

# 配置Kafka（instance.properties）
canal.serverMode=kafka
canal.destinations=muses
kafka.bootstrap.servers=127.0.0.1:9092

# 创建Topic
kafka-topics.sh --zookeeper zookeeper:2181 --topic topic-log --create --partitions 3 --replication-factor 3

# 配置Kafka
spring:
  cloud:
    stream:
      binders:
        log:
          type: kafka
      default-binder: log
      function:
        definition: logRecord
      bindings:
        logRecord-in-0:
          group: ${spring.application.name}
          binder: log
          destination: ${system.topic.log:topic-log}
#         content-type: text/plain