目前，我正在使用debezium将mysql binlog中的数据更改传输到kafka，然后再传输到bigquery。
我使用分布式模式配置 snapshot.mode=initial . 但不幸的是，mysql示例中的数据量太大，因为debezium从一开始就不断地读取binlog。
我在试着 snapshot.mode=schema_only 以及 auto.offset.reset=latest . 但mysql示例中仍然有一个峰值。
是否有适当的配置来最小化读取binlog的繁重消耗？