public static Client createKustoEngineClient()

in src/main/java/com/microsoft/azure/kusto/kafka/connect/sink/KustoSinkTask.java [132:138]

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

    public static Client createKustoEngineClient(KustoSinkConfig config) {
        try {
            return ClientFactory.createClient(createKustoEngineConnectionString(config, config.getKustoEngineUrl()));
        } catch (Exception e) {
            throw new ConnectException("Failed to initialize KustoEngineClient", e);
        }
    }