Tested System managed identity

Author: dceravigupta

plugins/out_azure_kusto/azure_kusto_conf.c

@@ -641,7 +641,7 @@ struct flb_azure_kusto *flb_azure_kusto_conf_create(struct flb_output_instance *
             }
 
             flb_sds_snprintf(&ctx->oauth_url, flb_sds_alloc(ctx->oauth_url),
-                            FLB_AZURE_MSIAUTH_URL_TEMPLATE, "");
+                            FLB_AZURE_MSIAUTH_URL_TEMPLATE, "", "");
 
         } else {
             /* user assigned managed identity */
@@ -656,7 +656,7 @@ struct flb_azure_kusto *flb_azure_kusto_conf_create(struct flb_output_instance *
             }
 
             flb_sds_snprintf(&ctx->oauth_url, flb_sds_alloc(ctx->oauth_url),
-                            FLB_AZURE_MSIAUTH_URL_TEMPLATE, ctx->managed_identity_client_id);
+                            FLB_AZURE_MSIAUTH_URL_TEMPLATE, "&client_id=", ctx->managed_identity_client_id);
         }
     }
     else {

plugins/out_azure_kusto/azure_msiauth.h

@@ -21,7 +21,7 @@
 
 /* MSAL authorization URL  */
 #define FLB_AZURE_MSIAUTH_URL_TEMPLATE \
-    "http://169.254.169.254/metadata/identity/oauth2/token?api-version=2021-02-01%s&resource=https://api.kusto.windows.net"
+    "http://169.254.169.254/metadata/identity/oauth2/token?api-version=2021-02-01%s%s&resource=https://api.kusto.windows.net"
 
 char *flb_azure_msiauth_token_get(struct flb_oauth2 *ctx);
 

src/flb_oauth2.c

@@ -227,11 +227,11 @@ struct flb_oauth2 *flb_oauth2_create(struct flb_config *config,
     }
 
     /* Create Upstream context */
-    if (strcmp(prot, "https")) {
+    if (strcmp(prot, "https") == 0) {
         ctx->u = flb_upstream_create_url(config, auth_url,
                                         FLB_IO_TLS, ctx->tls);
     }
-    else if (strcmp(prot, "http")) {
+    else if (strcmp(prot, "http") == 0) {
         ctx->u = flb_upstream_create_url(config, auth_url,
                                         FLB_IO_TCP, NULL);
     }