public static KafkaScanStartupMode forName(String name) {
        for (KafkaScanStartupMode startupMode : values()) {
            if (startupMode.getValue().equals(name.toLowerCase(Locale.ROOT))) {
                return startupMode;
            }
        }
        throw new IllegalArgumentException(String.format("Unsupported KafkaScanStartupMode=%s for Inlong", name));
    }
kafka consumer scan startup mode enum
inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/enums/KafkaScanStartupMode.java