Flink CDC作为客户端,向PostgreSQL发起逻辑复制连接请求。

PostgreSQL接受连接请求,并创建一个专用的复制连接。

Flink CDC向PostgreSQL发送复制参数,如复制槽名称、起始LSN位置、解码插件等。

PostgreSQL根据复制参数配置复制槽,并开始将WAL日志发送给解码插件进行解码。

解码插件将解码后的数据变更事件通过逻辑复制流复制协议发送给Flink CDC。

Flink CDC接收数据变更事件,并根据消息格式解析出事件类型、表信息、数据内容等。