protected void setParallelism(Integer parallelism, DataStreamSource kafkaSource) {
        if (parallelism > 0) {
            kafkaSource.setParallelism(parallelism);
        }
    }
Date: 2020/3/20
Company: www.dtstack.com
@author maqi
kafka-base/kafka-base-source/src/main/java/com/dtstack/flink/sql/source/kafka/AbstractKafkaSource.java