主库业务比较关键，从库可以做Flink CDC同步吗？

是的，Flink CDC 支持从库进行数据同步，但需要对从库进行特定配置以确保其能够正确记录主库同步过来的数据变更。以下是具体的操作步骤和注意事项：

1. 从库配置

为了支持 Flink CDC 监听从库，需要在从库上启用以下配置： - log-slave-updates = 1
该参数确保从库在接收主库同步过来的数据时，会将这些数据写入从库自身的 Binlog 文件中。

• GTID 模式（如果主库启用了 GTID）
  如果主库启用了 GTID（全局事务标识符）模式，则从库也必须启用 GTID 模式，并进行以下配置：

  gtid_mode = on
  enforce_gtid_consistency = on
  

2. Flink CDC 配置

在 Flink CDC 中连接从库时，需确保以下几点： - 指定从库地址：在 Flink CDC 的 Source 配置中，使用从库的 IP 地址或域名作为 MySQL 数据源的连接地址。 - 设置正确的 server-time-zone 参数：确保 Flink CDC 配置中的 server-time-zone 参数与从库的时区一致，避免因时区问题导致数据解析错误。

3. 注意事项

• Binlog 格式要求
  确保从库的 Binlog 格式为 ROW 模式。如果当前格式为 MIXED 或 STATEMENT，可以通过以下命令修改：

  show variables like "binlog_format";
  set global binlog_format=ROW;
  

  注意：修改 Binlog 格式可能会影响数据库性能，请在低峰期操作并做好备份。

• 权限要求
  确保用于 Flink CDC 连接的数据库用户具有从库的 REPLICATION SLAVE 和 REPLICATION CLIENT 权限。

• Binlog 保留时间
  如果从库的 Binlog 文件过期时间较短，可能会导致 Flink CDC 无法读取历史数据。建议将 Binlog 保留时间设置为至少 7 天：

  show variables like 'expire_logs_days';
  set global expire_logs_days=7;
  

4. 优势

• 降低主库压力：通过从库进行同步，可以有效减少主库的负载，避免因 CDC 同步任务对主库业务造成影响。
• 高可用性：从库通常作为主库的备份，使用从库进行同步可以提高系统的容错能力。

5. 验证同步状态

在完成配置后，可以通过以下方式验证 Flink CDC 是否正常工作： - 监控指标：观察 Flink 作业的 currentEmitEventTimeLag 指标，确认是否已进入增量数据同步阶段。 - 日志检查：查看 Flink 作业日志中是否出现 BinlogSplitReader is created 日志，确认全量数据同步已完成。

通过以上配置和注意事项，您可以安全地使用从库进行 Flink CDC 数据同步，同时确保主库的业务稳定性不受影响。