@Override
    public boolean check() {
        Preconditions.checkNotNull(getType(), "kafka of type is required");
        Preconditions.checkNotNull(bootstrapServers, "kafka of bootstrapServers is required");
        Preconditions.checkNotNull(topic, "kafka of topic is required");

        if (StringUtils.equalsIgnoreCase(getSinkDataType(), FormatType.AVRO.name())) {
            avroParamCheck();
        }

        return false;
    }
Date: 2018/12/18
Company: www.dtstack.com

@author DocLi
@modifyer maqi
kafka-base/kafka-base-sink/src/main/java/com/dtstack/flink/sql/sink/kafka/table/KafkaSinkTableInfo.java