public boolean isDlqEnabled()

in src/main/java/com/microsoft/azure/kusto/kafka/connect/sink/KustoSinkConfig.java [425:434]

• 10 lines of code
• 5 McCabe index (conditional complexity)

    public boolean isDlqEnabled() {
        if (!getDlqBootstrapServers().isEmpty() && StringUtils.isNotEmpty(getDlqTopicName())) {
            return true;
        } else if (getDlqBootstrapServers().isEmpty() && StringUtils.isEmpty(getDlqTopicName())) {
            return false;
        } else {
            throw new ConfigException("To enable Miscellaneous Dead-Letter Queue configuration please configure both " +
                    "`misc.deadletterqueue.bootstrap.servers` and `misc.deadletterqueue.topic.name` configurations ");
        }
    }