You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by "casel.chen" <ca...@126.com> on 2021/03/11 00:30:34 UTC

flink cdc遇到数据源大事务怎么处理？

flink cdc对接上游的mysql或pg业务库时遇到业务库大批量修数或schema变更是怎么处理的？
会不会瞬间产生很多changelog records打爆flink应用？如果会的话应该要如何避免呢？谢谢！