in src/main/java/org/apache/doris/kafka/connector/converter/RecordTypeRegister.java [68:100]
protected void registerTypes() {
// Supported common Debezium data types
registerType(DateType.INSTANCE);
registerType(TimeType.INSTANCE);
registerType(MicroTimeType.INSTANCE);
registerType(TimestampType.INSTANCE);
registerType(MicroTimestampType.INSTANCE);
registerType(NanoTimeType.INSTANCE);
registerType(NanoTimestampType.INSTANCE);
registerType(ZonedTimeType.INSTANCE);
registerType(ZonedTimestampType.INSTANCE);
registerType(VariableScaleDecimalType.INSTANCE);
registerType(PointType.INSTANCE);
registerType(GeographyType.INSTANCE);
registerType(GeometryType.INSTANCE);
registerType(ArrayType.INSTANCE);
// Supported connect data types
registerType(ConnectBooleanType.INSTANCE);
registerType(ConnectBytesType.INSTANCE);
registerType(ConnectDateType.INSTANCE);
registerType(ConnectDecimalType.INSTANCE);
registerType(ConnectFloat32Type.INSTANCE);
registerType(ConnectFloat64Type.INSTANCE);
registerType(ConnectInt8Type.INSTANCE);
registerType(ConnectInt16Type.INSTANCE);
registerType(ConnectInt32Type.INSTANCE);
registerType(ConnectInt64Type.INSTANCE);
registerType(ConnectStringType.INSTANCE);
registerType(ConnectTimestampType.INSTANCE);
registerType(ConnectTimeType.INSTANCE);
registerType(ConnectMapToConnectStringType.INSTANCE);
}