void validate()

in src/main/java/com/microsoft/azure/kusto/kafka/connect/sink/TopicToTableMapping.java [75:87]

• 11 lines of code
• 7 McCabe index (conditional complexity)

    void validate() {
        if (null == db || db.isEmpty()) {
            throw new ConfigException("'db' must be provided for each mapping");
        }

        if (null == table || table.isEmpty()) {
            throw new ConfigException("'table' must be provided for each mapping");
        }

        if (null == topic || topic.isEmpty()) {
            throw new ConfigException("'topic' must be provided for each mapping");
        }
    }