connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/connector/DorisSinkConfig.java [223:306]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        tableNameFormat = config.getString(TABLE_NAME_FORMAT, TABLE_NAME_FORMAT_DEFAULT).trim();
        tableFromHeader = getBoolean(config, TABLE_NAME_FROM_HEADER, false);
        batchSize = config.getInt(BATCH_SIZE, BATCH_SIZE_DEFAULT);

        maxRetries = config.getInt(MAX_RETRIES, MAX_RETRIES_DEFAULT);
        retryBackoffMs = config.getInt(RETRY_BACKOFF_MS, RETRY_BACKOFF_MS_DEFAULT);
        autoCreate = getBoolean(config, AUTO_CREATE, AUTO_CREATE_DEFAULT);
        autoEvolve = getBoolean(config, AUTO_EVOLVE, AUTO_EVOLVE_DEFAULT);
        if (Objects.nonNull(config.getString(INSERT_MODE))) {
            insertMode = InsertMode.valueOf(config.getString(INSERT_MODE, INSERT_MODE_DEFAULT).toUpperCase());
        }
        deleteEnabled = getBoolean(config, DELETE_ENABLED, DELETE_ENABLED_DEFAULT);
        pkMode = PrimaryKeyMode.valueOf(config.getString(PK_MODE, PK_MODE_DEFAULT).toUpperCase());
        pkFields = getList(config, PK_FIELDS);
        if (deleteEnabled && pkMode != PrimaryKeyMode.RECORD_KEY) {
            throw new ConfigException(
                    "Primary key mode must be 'record_key' when delete support is enabled");
        }
        fieldsWhitelist = new HashSet<>(getList(config, FIELDS_WHITELIST));
        // table white list
        tableWhitelist = new HashSet<>(getList(config, TABLE_WHITE_LIST_CONFIG));
        String dbTimeZone = config.getString(DB_TIMEZONE_CONFIG, DB_TIMEZONE_DEFAULT);
        timeZone = TimeZone.getTimeZone(ZoneId.of(dbTimeZone));
        tableTypes = TableType.parse(getList(config, TABLE_TYPES_CONFIG, TABLE_TYPES_DEFAULT));
    }

    public String getTableNameFormat() {
        return tableNameFormat;
    }

    public boolean isTableFromHeader() {
        return tableFromHeader;
    }

    public int getMaxRetries() {
        return maxRetries;
    }

    public int getRetryBackoffMs() {
        return retryBackoffMs;
    }

    public int getBatchSize() {
        return batchSize;
    }

    public boolean isDeleteEnabled() {
        return deleteEnabled;
    }

    public boolean isAutoCreate() {
        return autoCreate;
    }

    public boolean isAutoEvolve() {
        return autoEvolve;
    }

    public InsertMode getInsertMode() {
        return insertMode;
    }

    public PrimaryKeyMode getPkMode() {
        return pkMode;
    }

    public List<String> getPkFields() {
        return pkFields;
    }

    public Set<String> getFieldsWhitelist() {
        return fieldsWhitelist;
    }

    public Set<String> getTableWhitelist() {
        return tableWhitelist;
    }

    public TimeZone getTimeZone() {
        return timeZone;
    }

    public EnumSet<TableType> getTableTypes() {
        return tableTypes;
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/JdbcSinkConfig.java [119:204]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        tableNameFormat = config.getString(TABLE_NAME_FORMAT, TABLE_NAME_FORMAT_DEFAULT).trim();
        tableFromHeader = getBoolean(config, TABLE_NAME_FROM_HEADER, false);
        batchSize = config.getInt(BATCH_SIZE, BATCH_SIZE_DEFAULT);

        maxRetries = config.getInt(MAX_RETRIES, MAX_RETRIES_DEFAULT);
        retryBackoffMs = config.getInt(RETRY_BACKOFF_MS, RETRY_BACKOFF_MS_DEFAULT);
        autoCreate = getBoolean(config, AUTO_CREATE, AUTO_CREATE_DEFAULT);
        autoEvolve = getBoolean(config, AUTO_EVOLVE, AUTO_EVOLVE_DEFAULT);
        if (Objects.nonNull(config.getString(INSERT_MODE))) {
            insertMode = InsertMode.valueOf(config.getString(INSERT_MODE, INSERT_MODE_DEFAULT).toUpperCase());
        }
        deleteEnabled = getBoolean(config, DELETE_ENABLED, DELETE_ENABLED_DEFAULT);
        pkMode = PrimaryKeyMode.valueOf(config.getString(PK_MODE, PK_MODE_DEFAULT).toUpperCase());
        pkFields = getList(config, PK_FIELDS);
        if (deleteEnabled && pkMode != PrimaryKeyMode.RECORD_KEY) {
            throw new ConfigException(
                    "Primary key mode must be 'record_key' when delete support is enabled");
        }
        fieldsWhitelist = new HashSet<>(getList(config, FIELDS_WHITELIST));
        // table white list
        tableWhitelist = new HashSet<>(getList(config, TABLE_WHITE_LIST_CONFIG));
        String dbTimeZone = config.getString(DB_TIMEZONE_CONFIG, DB_TIMEZONE_DEFAULT);
        timeZone = TimeZone.getTimeZone(ZoneId.of(dbTimeZone));
        tableTypes = TableType.parse(getList(config, TABLE_TYPES_CONFIG, TABLE_TYPES_DEFAULT));


    }

    public String getTableNameFormat() {
        return tableNameFormat;
    }

    public boolean isTableFromHeader() {
        return tableFromHeader;
    }

    public int getMaxRetries() {
        return maxRetries;
    }

    public int getRetryBackoffMs() {
        return retryBackoffMs;
    }

    public int getBatchSize() {
        return batchSize;
    }

    public boolean isDeleteEnabled() {
        return deleteEnabled;
    }

    public boolean isAutoCreate() {
        return autoCreate;
    }

    public boolean isAutoEvolve() {
        return autoEvolve;
    }

    public InsertMode getInsertMode() {
        return insertMode;
    }

    public PrimaryKeyMode getPkMode() {
        return pkMode;
    }

    public List<String> getPkFields() {
        return pkFields;
    }

    public Set<String> getFieldsWhitelist() {
        return fieldsWhitelist;
    }

    public Set<String> getTableWhitelist() {
        return tableWhitelist;
    }

    public TimeZone getTimeZone() {
        return timeZone;
    }

    public EnumSet<TableType> getTableTypes() {
        return tableTypes;
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -