protected String generateOperatorName(String tabName, String topicName) {
        return SOURCE_OPERATOR_NAME_TPL.replace("${topic}", topicName).replace("${table}", tabName);
    }
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