【测试类型：工具功能】【测试版本：5.1.0】问题描述：Debezium+Kafka反向迁移，源库和目标库表名一样，表结构不一样，源库插入数据，优化sink端报错提示

【标题描述】:Debezium+Kafka反向迁移，源库和目标库表名一样，表结构不一样，源库插入数据，优化sink端报错提示
【测试类型：工具功能】【测试版本：5.1.0】 问题描述：Debezium+Kafka反向迁移，源库和目标库表名一样，表结构不一样，源库插入数据，优化sink端报错提示

【操作系统和硬件信息】(查询命令: cat /etc/system-release, uname -a):
CentOS Linux release 7.6.1908 (Core)
Linux kwephis1163085 3.10.0-1062.el7.x86_64 #1 SMP Wed Aug 7 18:08:02 UTC 2019 x86_64 x86_64 x86_64 GNU/Linux

【测试环境】(单机/1主x备x级联备):单机

【被测功能】:Debezium+Kafka反向迁移

【测试类型】:工具功能

【数据库版本】(查询命令: gaussdb -V):
gaussdb (openGauss 5.1.0 build 68d1772f) compiled at 2023-05-24 00:09:56 commit 0 last mr

【预置条件】:
1.数据库状态正常，创建兼容B库和有逻辑复制权限的用户，配置pg_hba文件和wal_level = logical
2.反向迁移环境部署成功
（1）启动zookeeper
cd xxx/debezium_kafka/kafka_2.13-3.2.3
./bin/zookeeper-server-start.sh ./config/zookeeper.properties
（2）启动kafka
cd xxx/debezium_kafka/kafka_2.13-3.2.3
./bin/kafka-server-start.sh ./config/server.properties
（3）注册schema
cd xxx/debezium_kafka/confluent-5.5.1
schema-registry-start etc/schema-registry/schema-registry.properties
【操作步骤】(请填写详细的操作步骤):
1. openGauss建表

```
create table test1(v1 int);
```
2. mysql侧建表

```
create table test1(a year);
```
3.启动source和sink端
4. openGauss插入数据

```
insert into test1 values(1),(12),(20);
```

【预期输出】:步骤4执行后，sink端报错，不上报迁移进度，无失败sql生成

【实际输出】:步骤4执行后，sink端报错不明显，不上报迁移进度，无失败sql生成
![输入图片说明](https://foruda.gitee.com/images/1686205593773552184/a0f15bd9_8574640.png "屏幕截图")

【原因分析】:
1. 这个问题的根因
2. 问题推断过程
3. 还有哪些原因可能造成类似现象
4. 该问题是否有临时规避措施
5. 问题解决方案
6. 预计修复问题时间

【日志信息】(请附上日志文件、截图、coredump信息):

【测试代码】:

openGauss/debezium

内容风险标识

评论 (3)

openGauss/debezium .gitee-modal { width: 500px !important; }

内容风险标识