Debezium: Mysql LONGTEXT到Debezium的数据类型转换不正确

Question

mysql模式

 `Info` longtext,

相同字段的debezium模式

{
     "name": "Info",
      "type": [
          "null",
          "string"
       ],
      "default": null
},

当这些数据加载到Redshift中时，它会失败，因为它希望数据类型是大的，即VARCHAR(MAX)，但它得到了VARCHAR(255)，因为debezium没有将长文本转换为long。

请建议一下，为什么会发生这种情况。

Answer 1

请看一下https://debezium.io/documentation/reference/1.2/connectors/mysql.html#mysql-property-column-propagate-source-type

这会将类型constarint参数添加到模式中。

另外，IIUC你使用的是合流Avro转换器。如果是，则将enhanced.avro.schema.support和connect.meta.data设置为true。

在这种情况下，您需要将Debezium onstraint参数转换为接收器转换器支持的参数(如果提供了此类功能)。