diff --git a/plugins/outputs/azure_data_explorer/azure_data_explorer.go b/plugins/outputs/azure_data_explorer/azure_data_explorer.go index cca3837b7430e..c954b19d505b9 100644 --- a/plugins/outputs/azure_data_explorer/azure_data_explorer.go +++ b/plugins/outputs/azure_data_explorer/azure_data_explorer.go @@ -17,6 +17,7 @@ import ( "github.com/influxdata/telegraf" "github.com/influxdata/telegraf/config" + "github.com/influxdata/telegraf/internal" "github.com/influxdata/telegraf/internal/choice" "github.com/influxdata/telegraf/plugins/outputs" "github.com/influxdata/telegraf/plugins/serializers" @@ -58,6 +59,8 @@ func (*AzureDataExplorer) SampleConfig() string { // Initialize the client and the ingestor func (adx *AzureDataExplorer) Connect() error { conn := kusto.NewConnectionStringBuilder(adx.Endpoint).WithDefaultAzureCredential() + // Since init is called before connect, we can set the connector details here including the type. This will be used for telemetry and tracing. + conn.SetConnectorDetails("Telegraf", internal.ProductToken(), "", "", false, "") client, err := kusto.New(conn) if err != nil { return err