From cd7da156eb82164bae2b9b3652602ad2d44e3a55 Mon Sep 17 00:00:00 2001
From: wanggang <76527413@qq.com>
Date: Sat, 8 May 2021 17:28:14 +0800
Subject: [PATCH] update

Former-commit-id: 36dc7c8ccc3cf75c14b2306aaebad23c9d7691dd
Former-commit-id: 4371d768e03e3b3c74bf92274173a685f8e50e59
---
 labs/doris/Kafka2Doris/Worker.cs | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/labs/doris/Kafka2Doris/Worker.cs b/labs/doris/Kafka2Doris/Worker.cs
index ee2898d2..9a1b37b2 100644
--- a/labs/doris/Kafka2Doris/Worker.cs
+++ b/labs/doris/Kafka2Doris/Worker.cs
@@ -7,6 +7,8 @@ using System.Collections.Generic;
 using System.IO;
 using System.Linq;
 using System.Net.Http;
+using System.Net.Http.Headers;
+using System.Text;
 using System.Text.Json;
 using System.Threading;
 using System.Threading.Tasks;
@@ -85,6 +87,9 @@ namespace Kafka2Doris
                                     if(list.Count>0)
                                     {
                                         var httpClient = this._httpClientFactory.CreateClient();
+                                        var username = _config.GetValue("username", "root");
+                                        var password = _config.GetValue("password", "aA123456!");
+                                        httpClient.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Basic", Convert.ToBase64String(Encoding.UTF8.GetBytes($"{username}:{password}")));
                                         httpClient.DefaultRequestHeaders.Add("label", DateTime.Now.ToString());
                                         var url = $"{_config.GetValue("doris","http://localhost:8030")}/api/example/User/_stream_load";
                                         using (var multiContent = new MultipartFormDataContent())