我们所要实现以下几个回调函数： LogicalDecodeStartupCB startup_cb; LogicalDecodeBeginCB begin_cb; LogicalDecodeChangeCB change_cb; LogicalDecodeCommitCB commit_cb; LogicalDecodeShutdownCB shutdown_cb; 2016Postgres中国用户大会 被中止的事务及其内容不会被解码。 已提交事务的提交动作被解码，就会调 用必须提供的 commit_cb回调。在此之前， 如果有任何被修改 的行，将为所有被修 改的行调用change_cb回调。 一个事务中的每一个行修改，都将调用 必须提供的 change_cb回调，这种修改可 能是一个 INSERT、UPDATE或者 DELETE。 即使原始命令一次修改了多行，该回调 也会 为其中的每一行调用一次。 2016Postgres中国用户大会