private KafkaExtractNode buildKafkaExtractTimestamp() {
        List<FieldInfo> fields = Arrays.asList(
                new FieldInfo("log", new StringFormatInfo()));
        return new KafkaExtractNode("1", "kafka_input", fields, null,
                null, "topic_input", "localhost:9092",
                new RawFormat(), KafkaScanStartupMode.TIMESTAMP_MILLIS, null, "groupId",
                null, "1665198979108");
    }
build node relation

@param inputs  extract node
@param outputs load node
@return node relation
inlong-sort/sort-core/src/test/java/org/apache/inlong/sort/parser/KafkaSqlParseTest.java