flink cdc postgresql是不支持int8类型吗？

Flink CDC连接Postgres时,目前不直接支持Postgres的int8数据类型。

原因是:

Flink内部主要使用Java基本数据类型,而Java没有原生的int8类型。

Debezium作为CDC来源,它采用JSON序列化数据,也不支持将int8映射为特定JSON类型。

但是可以通过一下方式解决:

在Postgres中将int8列定义为int或者bigint。

在Flink SQL的项目转换中,将int/bigint强转为int8输出。

自定义用户定义函数(UDF)将int转换为int8。

扩展Flink内部数据类型支持int8。

使用自定义Deserialization函数映射为具体类。

所以对int8类型支持并不完美,但通过类型转换或者自定义函数等方式可以解决大部分需求。

主流做法是直接使用Postgres兼容类型如int或bigint代替。