private static boolean isStreamingPolicyEnabled()

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

• 6 lines of code
• 1 McCabe index (conditional complexity)

    private static boolean isStreamingPolicyEnabled(
            String entityType, String entityName, Client engineClient, String database) throws DataClientException, DataServiceException {
        KustoResultSetTable res = engineClient.execute(database, String.format(STREAMING_POLICY_SHOW_COMMAND, entityType, entityName)).getPrimaryResults();
        res.next();
        return res.getString("Policy") != null;
    }