diff --git a/plugins/out_azure_kusto/azure_kusto.c b/plugins/out_azure_kusto/azure_kusto.c index 58ac559dbdc..0b6a23e8b1d 100644 --- a/plugins/out_azure_kusto/azure_kusto.c +++ b/plugins/out_azure_kusto/azure_kusto.c @@ -24,6 +24,7 @@ #include #include #include +#include #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 index a5dedf2f8e1..be03d7610ee 100644 --- 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);