protected String[] getPartitionKeys(KafkaSinkTableInfo kafkaSinkTableInfo) {
        String keysStr = kafkaSinkTableInfo.getPartitionKeys();
        if (StringUtils.isNotBlank(keysStr)) {
            String[] keys = StringUtils.split(keysStr, ",");
            String[] cleanedKeys = Arrays.stream(keys)
                .map(x -> x.trim())
                .toArray(String[]::new);
            return cleanedKeys;
        }
        return null;
    }
Date: 2020/3/30
Company: www.dtstack.com
@author maqi
kafka-base/kafka-base-sink/src/main/java/com/dtstack/flink/sql/sink/kafka/AbstractKafkaSink.java