update

Former-commit-id: 08db8ba2d926079464c96b49bc4badb66952fd9d
Former-commit-id: a4b151063844765e5509e6775a1f81686d096cbf

labs/docker-swarm/data/conf/nfs4/exports.conf

@@ -0,0 +1 @@
+/exports *(rw,sync,no_subtree_check,fsid=0,no_root_squash)

labs/doris/Kafka2Doris/.gitignore

@@ -0,0 +1,16 @@
+*.bak
+*.suo
+*.db
+*.user
+.vs
+obj
+Obj
+bin
+Bin
+debug
+Debug
+release
+Release
+Logs
+logs
+node_modules

labs/doris/Kafka2Doris/Kafka2Doris.csproj

@@ -0,0 +1,13 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <OutputType>Exe</OutputType>
+    <TargetFramework>net5.0</TargetFramework>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <PackageReference Include="Confluent.Kafka" Version="1.6.3" />
+    <PackageReference Include="Microsoft.Extensions.Hosting" Version="5.0.0" />
+  </ItemGroup>
+
+</Project>

labs/doris/Kafka2Doris/Kafka2Doris.sln

@@ -0,0 +1,25 @@
+
+Microsoft Visual Studio Solution File, Format Version 12.00
+# Visual Studio Version 16
+VisualStudioVersion = 16.0.31205.134
+MinimumVisualStudioVersion = 10.0.40219.1
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Kafka2Doris", "Kafka2Doris.csproj", "{5DA8804A-D6EE-40D6-A3C5-3A160656CB1D}"
+EndProject
+Global
+	GlobalSection(SolutionConfigurationPlatforms) = preSolution
+		Debug|Any CPU = Debug|Any CPU
+		Release|Any CPU = Release|Any CPU
+	EndGlobalSection
+	GlobalSection(ProjectConfigurationPlatforms) = postSolution
+		{5DA8804A-D6EE-40D6-A3C5-3A160656CB1D}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{5DA8804A-D6EE-40D6-A3C5-3A160656CB1D}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{5DA8804A-D6EE-40D6-A3C5-3A160656CB1D}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{5DA8804A-D6EE-40D6-A3C5-3A160656CB1D}.Release|Any CPU.Build.0 = Release|Any CPU
+	EndGlobalSection
+	GlobalSection(SolutionProperties) = preSolution
+		HideSolutionNode = FALSE
+	EndGlobalSection
+	GlobalSection(ExtensibilityGlobals) = postSolution
+		SolutionGuid = {C9AE1A91-D599-4677-8B52-313448B44F38}
+	EndGlobalSection
+EndGlobal

labs/doris/Kafka2Doris/Program.cs

@@ -0,0 +1,31 @@
+using Microsoft.Extensions.Configuration;
+using Microsoft.Extensions.DependencyInjection;
+using Microsoft.Extensions.Hosting;
+using Microsoft.Extensions.Logging;
+
+namespace Kafka2Doris
+{
+    internal class Program
+    {
+        private static void Main(string[] args)
+        {
+            Host.CreateDefaultBuilder(args)
+                .ConfigureLogging(o =>
+                {
+                    o.AddConsole();
+                })
+                .ConfigureAppConfiguration((hostingContext, configuration) =>
+                {
+                    configuration
+                        .AddJsonFile("appsettings.json", optional: true, reloadOnChange: true)
+                        .AddJsonFile($"appsettings.{hostingContext.HostingEnvironment.EnvironmentName}.json", true, true);
+                })
+                .ConfigureServices((hostingContext, services) =>
+                {
+                    services.AddHostedService<Worker>();
+                })
+                .Build()
+                .Run();
+        }
+    }
+}

labs/doris/Kafka2Doris/Properties/launchSettings.json

@@ -0,0 +1,7 @@
+{
+  "profiles": {
+    "Kafka2Doris": {
+      "commandName": "Project"
+    }
+  }
+}

labs/doris/Kafka2Doris/Worker.cs

@@ -0,0 +1,31 @@
+using Microsoft.Extensions.Configuration;
+using Microsoft.Extensions.Hosting;
+using Microsoft.Extensions.Logging;
+using System;
+using System.Threading;
+using System.Threading.Tasks;
+
+namespace Kafka2Doris
+{
+    public class Worker : BackgroundService
+    {
+        private readonly ILogger<Worker> _logger;
+        private readonly IConfiguration _config;
+
+        public Worker(ILogger<Worker> logger, IConfiguration config)
+        {
+            this._logger = logger;
+            this._config = config;
+        }
+
+        protected override async Task ExecuteAsync(CancellationToken stoppingToken)
+        {
+            while (!stoppingToken.IsCancellationRequested)
+            {
+                _logger.LogInformation("Worker running at: {time}", DateTimeOffset.Now);
+                //读取kafka
+                await Task.Delay(this._config.GetValue("delay", 1000 * 60), stoppingToken);
+            }
+        }
+    }
+}

labs/doris/Kafka2Doris/appsettings.json

@@ -0,0 +1,4 @@
+{
+  "delay": 60,
+  "group": 1000
+}