【标题】(请简要描述下实现的内容)支持openGauss到PostgreSQL反向迁移

【实现内容】:在原有opengauss反向迁移到功能基础上实现openGauss到PostgreSQL反向迁移

【实现方案】:通过逻辑复制和发布订阅机制,对源端PostgreSQL数据库的xlog日志进行解析,根据解码出来的报文类型封装成不同的消息对象,以AVRO格式发送到Kafka中。sink端消费Kafka的消息,根据元数据组装解析成可执行的SQL在目标库回放。

【关联需求或issue】: https://e.gitee.com/opengaussorg/projects/676554/requirements/table?issue=IB0CQ8

【开发自验报告】:

  1. 请附上自验结果(内容或者截图)
    启动source端和sink端后对opengauss数据库表中数据进行增删改和ddl操作。
    openGauss端插入数据
    输入图片说明
    postgres端迁移成功
    输入图片说明
    openGauss端修改数据
    输入图片说明
    postgres端迁移成功
    输入图片说明
    openGauss端删除数据
    端
    postgres端迁移成功
    输入图片说明
    openGauss端修改表结构
    输入图片说明
    postgres端迁移成功
    输入图片说明
  2. 是否可以添加fastcheck测试用例,如是,请补充fastcheck用例
  3. 是否涉及资料修改,如是,在docs仓库补充资料
  4. 是否考虑支撑升级和在线扩容等扩展场景
  5. 是否考虑异常场景/并发场景/前向兼容/性能场景
  6. 是否对其他模块产生影响

【其他说明】: