private Map<String, String> configToMap(String patternPartitionMapStr) {
        if (patternPartitionMapStr == null) {
            return Collections.emptyMap();
        }

        Map<String, String> patternPartitionMap = new LinkedHashMap<>();
        for (String entry : patternPartitionMapStr.split(DELIMITER4)) {
            String pattern = entry.split(DELIMITER3)[0];
            String partition = entry.split(DELIMITER3)[1];
            patternPartitionMap.put(pattern, partition);
        }
        return patternPartitionMap;
    }
Partition mapping is performed according to the library name and table name rules,
and no matching is written to the default partition.
inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/partitioner/InLongFixedPartitionPartitioner.java