modified x-ms-user header

Signed-off-by: Tanmaya Panda <[email protected]>
fluent · Feb 12, 2024 · c080b8d · c080b8d
1 parent e1d2055
commit c080b8d
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 2 deletions.
diff --git a/plugins/out_azure_kusto/azure_kusto.c b/plugins/out_azure_kusto/azure_kusto.c
@@ -24,6 +24,7 @@
 #include <fluent-bit/flb_pack.h>
 #include <fluent-bit/flb_signv4.h>
 #include <fluent-bit/flb_log_event_decoder.h>
+#include <fluent-bit/flb_version.h>
 
 #include "azure_kusto.h"
 #include "azure_kusto_conf.h"
@@ -152,6 +153,13 @@ flb_sds_t execute_ingest_csl_command(struct flb_azure_kusto *ctx, const char *cs
                     flb_http_add_header(c, "Accept", 6, "application/json", 16);
                     flb_http_add_header(c, "Authorization", 13, token,
                                         flb_sds_len(token));
+
+                    /* added kusto specific headers for debugging requests */
+                    flb_http_add_header(c, "x-ms-user", 9, "Kusto.Fluent-Bit", 16);
+                    flb_http_add_header(c, "x-ms-client-request-id", 22, generate_uuid(), 36);
+                    flb_http_add_header(c, "x-ms-client-version", 10, FLB_VERSION_STR, strlen(FLB_VERSION_STR));
+                    flb_http_add_header(c, "x-ms-app", 8, "Kusto.Fluent-Bit", 16);
+
                     flb_http_buffer_size(c, FLB_HTTP_DATA_SIZE_MAX * 10);
 
                     /* Send HTTP request */

diff --git a/plugins/out_azure_kusto/azure_kusto_ingest.c b/plugins/out_azure_kusto/azure_kusto_ingest.c
@@ -166,7 +166,7 @@ static flb_sds_t azure_kusto_create_blob(struct flb_azure_kusto *ctx, flb_sds_t
                 flb_http_add_header(c, "x-ms-version", 12, "2019-12-12", 10);
 
                 /* added kusto specific headers for debugging requests */
-                flb_http_add_header(c, "x-ms-user", 9, "Fluent-Bit", 10);
+                flb_http_add_header(c, "x-ms-user", 9, "Kusto.Fluent-Bit", 16);
                 flb_http_add_header(c, "x-ms-client-request-id", 22, generate_uuid(), 36);
                 flb_http_add_header(c, "x-ms-client-version", 10, FLB_VERSION_STR, strlen(FLB_VERSION_STR));
                 flb_http_add_header(c, "x-ms-app", 8, "Kusto.Fluent-Bit", 16);
@@ -375,7 +375,7 @@ static int azure_kusto_enqueue_ingestion(struct flb_azure_kusto *ctx, flb_sds_t
                     flb_http_add_header(c, "x-ms-version", 12, "2019-12-12", 10);
 
                     /* added kusto specific headers for debugging requests */
-                    flb_http_add_header(c, "x-ms-user", 9, "Fluent-Bit", 10);
+                    flb_http_add_header(c, "x-ms-user", 9, "Kusto.Fluent-Bit", 16);
                     flb_http_add_header(c, "x-ms-client-request-id", 22, generate_uuid(), 36);
                     flb_http_add_header(c, "x-ms-client-version", 10, FLB_VERSION_STR, strlen(FLB_VERSION_STR));
                     flb_http_add_header(c, "x-ms-app", 8, "Kusto.Fluent-Bit", 16);