public static KafkaOffset forName(String name) {
        for (KafkaOffset dataFormat : values()) {
            if (dataFormat.getName().equals(name.toLowerCase(Locale.ROOT))) {
                return dataFormat;
            }
        }
        throw new IllegalArgumentException(String.format("Unsupported KafkaOffset=%s", name));
    }
Enum of auto offset reset strategy of Kafka.
inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/source/kafka/KafkaOffset.java