一、完整报错如下所示 二、报错产生原因 三、解决方法
一、完整报错如下所示Data row is smaller than a column index, internal schema representation is probably out of sync with real database schema
二、报错产生原因表结构发生变化 当删除debezium connector，重新接入debezium connector出现上面错误 错误的原因是数据和表结构字段不一致 三、解决方法
清理history topic数据，清理方法可以直接删除kafka Topic，还可以通过代码删除kafka topic数据 重新初始化表结构，模式选择schema_only
删除Topic数据的方法请参考下面两篇博客：
