src/main/java/org/apache/doris/kafka/connector/converter/type/AbstractTimeType.java [29:46]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    @Override
    public String getTypeName(Schema schema) {
        // NOTE:
        // The MySQL connector does not use the __debezium.source.column.scale parameter to pass
        // the time column's precision but instead uses the __debezium.source.column.length key
        // which differs from all other connector implementations.
        //
        final int precision = getTimePrecision(schema);
        return String.format(
                "%s(%s)",
                DorisType.DATETIME,
                Math.min(precision, DorisTypeProperties.MAX_SUPPORTED_DATE_TIME_PRECISION));
    }

    protected int getTimePrecision(Schema schema) {
        final String length = getSourceColumnLength(schema).orElse("0");
        final Optional<String> scale = getSourceColumnPrecision(schema);
        return scale.map(Integer::parseInt).orElseGet(() -> Integer.parseInt(length));
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



src/main/java/org/apache/doris/kafka/connector/converter/type/AbstractTimestampType.java [29:41]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    @Override
    public String getTypeName(Schema schema) {
        final int precision = getTimePrecision(schema);
        return String.format(
                "%s(%s)",
                DorisType.DATETIME,
                Math.min(precision, DorisTypeProperties.MAX_SUPPORTED_DATE_TIME_PRECISION));
    }

    protected int getTimePrecision(Schema schema) {
        final String length = getSourceColumnLength(schema).orElse("0");
        final Optional<String> scale = getSourceColumnPrecision(schema);
        return scale.map(Integer::parseInt).orElseGet(() -> Integer.parseInt(length));
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -