From 3443fd5bdc3473a7aa84307577d98d8dc4e8ecd5 Mon Sep 17 00:00:00 2001
From: Andreas Luxbauer <al@verag.ag>
Date: Fri, 5 Sep 2025 08:56:37 +0200
Subject: [PATCH] kafka

---
 DienstplanTV/App.config          | 16 ++++--
 UID/ADMIN.vbproj                 | 28 ++++++---
 UID/App.config                   | 98 +++++++++++++++++++-------------
 UID/packages.config              | 10 ++--
 UID/usrctlProcedures.Designer.vb | 12 ++++
 UID/usrctlProcedures.vb          | 24 ++++++++
 6 files changed, 131 insertions(+), 57 deletions(-)

diff --git a/DienstplanTV/App.config b/DienstplanTV/App.config
index dcf1914..08308f3 100644
--- a/DienstplanTV/App.config
+++ b/DienstplanTV/App.config
@@ -7,19 +7,19 @@
     <assemblyBinding xmlns="urn:schemas-microsoft-com:asm.v1">
       <dependentAssembly>
         <assemblyIdentity name="System.Runtime.CompilerServices.Unsafe" publicKeyToken="b03f5f7f11d50a3a" culture="neutral" />
-        <bindingRedirect oldVersion="0.0.0.0-5.0.0.0" newVersion="5.0.0.0" />
+        <bindingRedirect oldVersion="0.0.0.0-6.0.3.0" newVersion="6.0.3.0" />
       </dependentAssembly>
       <dependentAssembly>
         <assemblyIdentity name="System.Memory" publicKeyToken="cc7b13ffcd2ddd51" culture="neutral" />
-        <bindingRedirect oldVersion="0.0.0.0-4.0.1.1" newVersion="4.0.1.1" />
+        <bindingRedirect oldVersion="0.0.0.0-4.0.5.0" newVersion="4.0.5.0" />
       </dependentAssembly>
       <dependentAssembly>
         <assemblyIdentity name="System.Numerics.Vectors" publicKeyToken="b03f5f7f11d50a3a" culture="neutral" />
-        <bindingRedirect oldVersion="0.0.0.0-4.1.4.0" newVersion="4.1.4.0" />
+        <bindingRedirect oldVersion="0.0.0.0-4.1.6.0" newVersion="4.1.6.0" />
       </dependentAssembly>
       <dependentAssembly>
         <assemblyIdentity name="System.Buffers" publicKeyToken="cc7b13ffcd2ddd51" culture="neutral" />
-        <bindingRedirect oldVersion="0.0.0.0-4.0.3.0" newVersion="4.0.3.0" />
+        <bindingRedirect oldVersion="0.0.0.0-4.0.5.0" newVersion="4.0.5.0" />
       </dependentAssembly>
       <dependentAssembly>
         <assemblyIdentity name="GrapeCity.ActiveReports.Core.Document.Drawing.Gc" publicKeyToken="cc4967777c49a3ff" culture="neutral" />
@@ -77,6 +77,14 @@
         <assemblyIdentity name="System.Threading.Tasks.Extensions" publicKeyToken="cc7b13ffcd2ddd51" culture="neutral" />
         <bindingRedirect oldVersion="0.0.0.0-4.2.0.1" newVersion="4.2.0.1" />
       </dependentAssembly>
+      <dependentAssembly>
+        <assemblyIdentity name="System.Text.Json" publicKeyToken="cc7b13ffcd2ddd51" culture="neutral" />
+        <bindingRedirect oldVersion="0.0.0.0-5.0.0.2" newVersion="5.0.0.2" />
+      </dependentAssembly>
+      <dependentAssembly>
+        <assemblyIdentity name="System.Text.Encodings.Web" publicKeyToken="cc7b13ffcd2ddd51" culture="neutral" />
+        <bindingRedirect oldVersion="0.0.0.0-5.0.0.1" newVersion="5.0.0.1" />
+      </dependentAssembly>
     </assemblyBinding>
   </runtime>
 </configuration>
diff --git a/UID/ADMIN.vbproj b/UID/ADMIN.vbproj
index e94965f..006a7f8 100644
--- a/UID/ADMIN.vbproj
+++ b/UID/ADMIN.vbproj
@@ -1,5 +1,6 @@
 <?xml version="1.0" encoding="utf-8"?>
 <Project ToolsVersion="12.0" DefaultTargets="Build" xmlns="http://schemas.microsoft.com/developer/msbuild/2003">
+  <Import Project="..\packages\librdkafka.redist.2.11.1\build\librdkafka.redist.props" Condition="Exists('..\packages\librdkafka.redist.2.11.1\build\librdkafka.redist.props')" />
   <Import Project="$(MSBuildExtensionsPath)\$(MSBuildToolsVersion)\Microsoft.Common.props" Condition="Exists('$(MSBuildExtensionsPath)\$(MSBuildToolsVersion)\Microsoft.Common.props')" />
   <PropertyGroup>
     <Configuration Condition=" '$(Configuration)' == '' ">Debug</Configuration>
@@ -29,6 +30,8 @@
     <ApplicationVersion>1.0.0.%2a</ApplicationVersion>
     <UseApplicationTrust>false</UseApplicationTrust>
     <BootstrapperEnabled>true</BootstrapperEnabled>
+    <NuGetPackageImportStamp>
+    </NuGetPackageImportStamp>
   </PropertyGroup>
   <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Debug|AnyCPU' ">
     <PlatformTarget>x64</PlatformTarget>
@@ -96,6 +99,9 @@
     <Reference Include="ClosedXML, Version=0.95.4.0, Culture=neutral, processorArchitecture=MSIL">
       <HintPath>..\packages\ClosedXML.0.95.4\lib\net46\ClosedXML.dll</HintPath>
     </Reference>
+    <Reference Include="Confluent.Kafka, Version=2.11.1.0, Culture=neutral, PublicKeyToken=12c514ca49093d1e, processorArchitecture=MSIL">
+      <HintPath>..\packages\Confluent.Kafka.2.11.1\lib\net462\Confluent.Kafka.dll</HintPath>
+    </Reference>
     <Reference Include="DocumentFormat.OpenXml, Version=2.7.2.0, Culture=neutral, PublicKeyToken=8fb06cb64d019a17, processorArchitecture=MSIL">
       <HintPath>..\packages\DocumentFormat.OpenXml.2.7.2\lib\net46\DocumentFormat.OpenXml.dll</HintPath>
     </Reference>
@@ -235,8 +241,8 @@
       <HintPath>..\packages\SSH.NET.2024.0.0\lib\net462\Renci.SshNet.dll</HintPath>
     </Reference>
     <Reference Include="System" />
-    <Reference Include="System.Buffers, Version=4.0.3.0, Culture=neutral, PublicKeyToken=cc7b13ffcd2ddd51, processorArchitecture=MSIL">
-      <HintPath>..\packages\System.Buffers.4.5.1\lib\net461\System.Buffers.dll</HintPath>
+    <Reference Include="System.Buffers, Version=4.0.5.0, Culture=neutral, PublicKeyToken=cc7b13ffcd2ddd51, processorArchitecture=MSIL">
+      <HintPath>..\packages\System.Buffers.4.6.1\lib\net462\System.Buffers.dll</HintPath>
     </Reference>
     <Reference Include="System.Configuration" />
     <Reference Include="System.Data" />
@@ -251,16 +257,16 @@
     <Reference Include="System.IO.Packaging, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b03f5f7f11d50a3a, processorArchitecture=MSIL">
       <HintPath>..\packages\System.IO.Packaging.4.0.0\lib\net46\System.IO.Packaging.dll</HintPath>
     </Reference>
-    <Reference Include="System.Memory, Version=4.0.1.1, Culture=neutral, PublicKeyToken=cc7b13ffcd2ddd51, processorArchitecture=MSIL">
-      <HintPath>..\packages\System.Memory.4.5.4\lib\net461\System.Memory.dll</HintPath>
+    <Reference Include="System.Memory, Version=4.0.5.0, Culture=neutral, PublicKeyToken=cc7b13ffcd2ddd51, processorArchitecture=MSIL">
+      <HintPath>..\packages\System.Memory.4.6.3\lib\net462\System.Memory.dll</HintPath>
     </Reference>
     <Reference Include="System.Net.Http" />
     <Reference Include="System.Numerics" />
-    <Reference Include="System.Numerics.Vectors, Version=4.1.4.0, Culture=neutral, PublicKeyToken=b03f5f7f11d50a3a, processorArchitecture=MSIL">
-      <HintPath>..\packages\System.Numerics.Vectors.4.5.0\lib\net46\System.Numerics.Vectors.dll</HintPath>
+    <Reference Include="System.Numerics.Vectors, Version=4.1.6.0, Culture=neutral, PublicKeyToken=b03f5f7f11d50a3a, processorArchitecture=MSIL">
+      <HintPath>..\packages\System.Numerics.Vectors.4.6.1\lib\net462\System.Numerics.Vectors.dll</HintPath>
     </Reference>
-    <Reference Include="System.Runtime.CompilerServices.Unsafe, Version=5.0.0.0, Culture=neutral, PublicKeyToken=b03f5f7f11d50a3a, processorArchitecture=MSIL">
-      <HintPath>..\packages\System.Runtime.CompilerServices.Unsafe.5.0.0\lib\net45\System.Runtime.CompilerServices.Unsafe.dll</HintPath>
+    <Reference Include="System.Runtime.CompilerServices.Unsafe, Version=6.0.3.0, Culture=neutral, PublicKeyToken=b03f5f7f11d50a3a, processorArchitecture=MSIL">
+      <HintPath>..\packages\System.Runtime.CompilerServices.Unsafe.6.1.2\lib\net462\System.Runtime.CompilerServices.Unsafe.dll</HintPath>
     </Reference>
     <Reference Include="System.Runtime.Serialization" />
     <Reference Include="System.Runtime.Serialization.Formatters.Soap" />
@@ -1146,6 +1152,12 @@
     </ProjectReference>
   </ItemGroup>
   <Import Project="$(MSBuildToolsPath)\Microsoft.VisualBasic.targets" />
+  <Target Name="EnsureNuGetPackageBuildImports" BeforeTargets="PrepareForBuild">
+    <PropertyGroup>
+      <ErrorText>Dieses Projekt verweist auf mindestens ein NuGet-Paket, das auf diesem Computer fehlt. Verwenden Sie die Wiederherstellung von NuGet-Paketen, um die fehlenden Dateien herunterzuladen. Weitere Informationen finden Sie unter "http://go.microsoft.com/fwlink/?LinkID=322105". Die fehlende Datei ist "{0}".</ErrorText>
+    </PropertyGroup>
+    <Error Condition="!Exists('..\packages\librdkafka.redist.2.11.1\build\librdkafka.redist.props')" Text="$([System.String]::Format('$(ErrorText)', '..\packages\librdkafka.redist.2.11.1\build\librdkafka.redist.props'))" />
+  </Target>
   <!-- To modify your build process, add your task inside one of the targets below and uncomment it. 
        Other similar extension points exist, see Microsoft.Common.targets.
   <Target Name="BeforeBuild">
diff --git a/UID/App.config b/UID/App.config
index de0bde4..a3c1594 100644
--- a/UID/App.config
+++ b/UID/App.config
@@ -1,16 +1,16 @@
-<?xml version="1.0" encoding="utf-8"?>
+<?xml version="1.0" encoding="utf-8"?>
 <configuration>
     <configSections>
         <sectionGroup name="userSettings" type="System.Configuration.UserSettingsGroup, System, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
-            <section name="ADMIN.My.MySettings" type="System.Configuration.ClientSettingsSection, System, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089" allowExeDefinition="MachineToLocalUser" requirePermission="false"/>
+            <section name="ADMIN.My.MySettings" type="System.Configuration.ClientSettingsSection, System, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089" allowExeDefinition="MachineToLocalUser" requirePermission="false" />
         </sectionGroup>
     </configSections>
     <connectionStrings>
-        <add name="ADMIN.My.MySettings.connToUID" connectionString="Data Source=DEVELOPER\DEVSQL;Initial Catalog=UID;Persist Security Info=True;User ID=sa;Password=BmWr501956" providerName="System.Data.SqlClient"/>
-        <add name="ADMIN.My.MySettings.connToAdminDEV" connectionString="Data Source=DEVELOPER\DEVSQL;Initial Catalog=ADMIN;Persist Security Info=True;User ID=sa;Password=BmWr501956" providerName="System.Data.SqlClient"/>
+        <add name="ADMIN.My.MySettings.connToUID" connectionString="Data Source=DEVELOPER\DEVSQL;Initial Catalog=UID;Persist Security Info=True;User ID=sa;Password=BmWr501956" providerName="System.Data.SqlClient" />
+        <add name="ADMIN.My.MySettings.connToAdminDEV" connectionString="Data Source=DEVELOPER\DEVSQL;Initial Catalog=ADMIN;Persist Security Info=True;User ID=sa;Password=BmWr501956" providerName="System.Data.SqlClient" />
     </connectionStrings>
     <startup>
-        <supportedRuntime version="v4.0" sku=".NETFramework,Version=v4.8"/>
+        <supportedRuntime version="v4.0" sku=".NETFramework,Version=v4.8" />
     </startup>
     <userSettings>
         <ADMIN.My.MySettings>
@@ -26,145 +26,161 @@
  
           <dependentAssembly>
  
-              <assemblyIdentity name="System.Runtime.CompilerServices.Unsafe" publicKeyToken="b03f5f7f11d50a3a" culture="neutral"/>
+              <assemblyIdentity name="System.Runtime.CompilerServices.Unsafe" publicKeyToken="b03f5f7f11d50a3a" culture="neutral" />
  
-              <bindingRedirect oldVersion="0.0.0.0-5.0.0.0" newVersion="5.0.0.0"/>
+              <bindingRedirect oldVersion="0.0.0.0-6.0.3.0" newVersion="6.0.3.0" />
  
           </dependentAssembly>
  
           <dependentAssembly>
  
-              <assemblyIdentity name="System.Memory" publicKeyToken="cc7b13ffcd2ddd51" culture="neutral"/>
+              <assemblyIdentity name="System.Memory" publicKeyToken="cc7b13ffcd2ddd51" culture="neutral" />
  
-              <bindingRedirect oldVersion="0.0.0.0-4.0.1.1" newVersion="4.0.1.1"/>
+              <bindingRedirect oldVersion="0.0.0.0-4.0.5.0" newVersion="4.0.5.0" />
  
           </dependentAssembly>
  
           <dependentAssembly>
  
-              <assemblyIdentity name="System.Numerics.Vectors" publicKeyToken="b03f5f7f11d50a3a" culture="neutral"/>
+              <assemblyIdentity name="System.Numerics.Vectors" publicKeyToken="b03f5f7f11d50a3a" culture="neutral" />
  
-              <bindingRedirect oldVersion="0.0.0.0-4.1.4.0" newVersion="4.1.4.0"/>
+              <bindingRedirect oldVersion="0.0.0.0-4.1.6.0" newVersion="4.1.6.0" />
  
           </dependentAssembly>
  
           <dependentAssembly>
  
-              <assemblyIdentity name="System.Buffers" publicKeyToken="cc7b13ffcd2ddd51" culture="neutral"/>
+              <assemblyIdentity name="System.Buffers" publicKeyToken="cc7b13ffcd2ddd51" culture="neutral" />
  
-              <bindingRedirect oldVersion="0.0.0.0-4.0.3.0" newVersion="4.0.3.0"/>
+              <bindingRedirect oldVersion="0.0.0.0-4.0.5.0" newVersion="4.0.5.0" />
  
           </dependentAssembly>
  
           <dependentAssembly>
  
-              <assemblyIdentity name="GrapeCity.ActiveReports.Core.Document.Drawing.Gc" publicKeyToken="cc4967777c49a3ff" culture="neutral"/>
+              <assemblyIdentity name="GrapeCity.ActiveReports.Core.Document.Drawing.Gc" publicKeyToken="cc4967777c49a3ff" culture="neutral" />
  
-              <bindingRedirect oldVersion="0.0.0.0-2.1.4.0" newVersion="2.1.4.0"/>
+              <bindingRedirect oldVersion="0.0.0.0-2.1.4.0" newVersion="2.1.4.0" />
  
           </dependentAssembly>
  
           <dependentAssembly>
  
-              <assemblyIdentity name="GrapeCity.ActiveReports.Core.Document" publicKeyToken="cc4967777c49a3ff" culture="neutral"/>
+              <assemblyIdentity name="GrapeCity.ActiveReports.Core.Document" publicKeyToken="cc4967777c49a3ff" culture="neutral" />
  
-              <bindingRedirect oldVersion="0.0.0.0-2.1.4.0" newVersion="2.1.4.0"/>
+              <bindingRedirect oldVersion="0.0.0.0-2.1.4.0" newVersion="2.1.4.0" />
  
           </dependentAssembly>
  
           <dependentAssembly>
  
-              <assemblyIdentity name="GrapeCity.ActiveReports.Core.Document.Drawing.Gdi" publicKeyToken="cc4967777c49a3ff" culture="neutral"/>
+              <assemblyIdentity name="GrapeCity.ActiveReports.Core.Document.Drawing.Gdi" publicKeyToken="cc4967777c49a3ff" culture="neutral" />
  
-              <bindingRedirect oldVersion="0.0.0.0-2.1.4.0" newVersion="2.1.4.0"/>
+              <bindingRedirect oldVersion="0.0.0.0-2.1.4.0" newVersion="2.1.4.0" />
  
           </dependentAssembly>
  
           <dependentAssembly>
  
-              <assemblyIdentity name="GrapeCity.ActiveReports.Core.Rendering" publicKeyToken="cc4967777c49a3ff" culture="neutral"/>
+              <assemblyIdentity name="GrapeCity.ActiveReports.Core.Rendering" publicKeyToken="cc4967777c49a3ff" culture="neutral" />
  
-              <bindingRedirect oldVersion="0.0.0.0-2.3.5.0" newVersion="2.3.5.0"/>
+              <bindingRedirect oldVersion="0.0.0.0-2.3.5.0" newVersion="2.3.5.0" />
  
           </dependentAssembly>
  
           <dependentAssembly>
  
-              <assemblyIdentity name="GrapeCity.ActiveReports" publicKeyToken="cc4967777c49a3ff" culture="neutral"/>
+              <assemblyIdentity name="GrapeCity.ActiveReports" publicKeyToken="cc4967777c49a3ff" culture="neutral" />
  
-              <bindingRedirect oldVersion="0.0.0.0-15.2.4.0" newVersion="15.2.4.0"/>
+              <bindingRedirect oldVersion="0.0.0.0-15.2.4.0" newVersion="15.2.4.0" />
  
           </dependentAssembly>
  
           <dependentAssembly>
  
-              <assemblyIdentity name="GrapeCity.ActiveReports.Core.Drawing.Gc" publicKeyToken="cc4967777c49a3ff" culture="neutral"/>
+              <assemblyIdentity name="GrapeCity.ActiveReports.Core.Drawing.Gc" publicKeyToken="cc4967777c49a3ff" culture="neutral" />
  
-              <bindingRedirect oldVersion="0.0.0.0-2.3.5.0" newVersion="2.3.5.0"/>
+              <bindingRedirect oldVersion="0.0.0.0-2.3.5.0" newVersion="2.3.5.0" />
  
           </dependentAssembly>
  
           <dependentAssembly>
  
-              <assemblyIdentity name="GrapeCity.ActiveReports.Document" publicKeyToken="cc4967777c49a3ff" culture="neutral"/>
+              <assemblyIdentity name="GrapeCity.ActiveReports.Document" publicKeyToken="cc4967777c49a3ff" culture="neutral" />
  
-              <bindingRedirect oldVersion="0.0.0.0-15.2.4.0" newVersion="15.2.4.0"/>
+              <bindingRedirect oldVersion="0.0.0.0-15.2.4.0" newVersion="15.2.4.0" />
  
           </dependentAssembly>
  
           <dependentAssembly>
  
-              <assemblyIdentity name="GrapeCity.ActiveReports.Core.Rdl" publicKeyToken="cc4967777c49a3ff" culture="neutral"/>
+              <assemblyIdentity name="GrapeCity.ActiveReports.Core.Rdl" publicKeyToken="cc4967777c49a3ff" culture="neutral" />
  
-              <bindingRedirect oldVersion="0.0.0.0-2.3.5.0" newVersion="2.3.5.0"/>
+              <bindingRedirect oldVersion="0.0.0.0-2.3.5.0" newVersion="2.3.5.0" />
  
           </dependentAssembly>
  
           <dependentAssembly>
  
-              <assemblyIdentity name="GrapeCity.ActiveReports.Core.Drawing.Gdi" publicKeyToken="cc4967777c49a3ff" culture="neutral"/>
+              <assemblyIdentity name="GrapeCity.ActiveReports.Core.Drawing.Gdi" publicKeyToken="cc4967777c49a3ff" culture="neutral" />
  
-              <bindingRedirect oldVersion="0.0.0.0-2.3.5.0" newVersion="2.3.5.0"/>
+              <bindingRedirect oldVersion="0.0.0.0-2.3.5.0" newVersion="2.3.5.0" />
  
           </dependentAssembly>
  
           <dependentAssembly>
  
-              <assemblyIdentity name="GrapeCity.ActiveReports.Win" publicKeyToken="cc4967777c49a3ff" culture="neutral"/>
+              <assemblyIdentity name="GrapeCity.ActiveReports.Win" publicKeyToken="cc4967777c49a3ff" culture="neutral" />
  
-              <bindingRedirect oldVersion="0.0.0.0-15.2.4.0" newVersion="15.2.4.0"/>
+              <bindingRedirect oldVersion="0.0.0.0-15.2.4.0" newVersion="15.2.4.0" />
  
           </dependentAssembly>
  
           <dependentAssembly>
  
-              <assemblyIdentity name="Renci.SshNet" publicKeyToken="1cee9f8bde3db106" culture="neutral"/>
+              <assemblyIdentity name="Renci.SshNet" publicKeyToken="1cee9f8bde3db106" culture="neutral" />
  
-              <bindingRedirect oldVersion="0.0.0.0-2024.0.0.0" newVersion="2024.0.0.0"/>
+              <bindingRedirect oldVersion="0.0.0.0-2024.0.0.0" newVersion="2024.0.0.0" />
  
           </dependentAssembly>
  
           <dependentAssembly>
  
-              <assemblyIdentity name="BouncyCastle.Crypto" publicKeyToken="0e99375e54769942" culture="neutral"/>
+              <assemblyIdentity name="BouncyCastle.Crypto" publicKeyToken="0e99375e54769942" culture="neutral" />
  
-              <bindingRedirect oldVersion="0.0.0.0-1.8.2.0" newVersion="1.8.2.0"/>
+              <bindingRedirect oldVersion="0.0.0.0-1.8.2.0" newVersion="1.8.2.0" />
  
           </dependentAssembly>
  
           <dependentAssembly>
  
-              <assemblyIdentity name="Microsoft.Bcl.AsyncInterfaces" publicKeyToken="cc7b13ffcd2ddd51" culture="neutral"/>
+              <assemblyIdentity name="Microsoft.Bcl.AsyncInterfaces" publicKeyToken="cc7b13ffcd2ddd51" culture="neutral" />
  
-              <bindingRedirect oldVersion="0.0.0.0-5.0.0.0" newVersion="5.0.0.0"/>
+              <bindingRedirect oldVersion="0.0.0.0-5.0.0.0" newVersion="5.0.0.0" />
  
           </dependentAssembly>
  
           <dependentAssembly>
  
-              <assemblyIdentity name="System.Threading.Tasks.Extensions" publicKeyToken="cc7b13ffcd2ddd51" culture="neutral"/>
+              <assemblyIdentity name="System.Threading.Tasks.Extensions" publicKeyToken="cc7b13ffcd2ddd51" culture="neutral" />
  
-              <bindingRedirect oldVersion="0.0.0.0-4.2.0.1" newVersion="4.2.0.1"/>
+              <bindingRedirect oldVersion="0.0.0.0-4.2.0.1" newVersion="4.2.0.1" />
+ 
+          </dependentAssembly>
+ 
+          <dependentAssembly>
+ 
+              <assemblyIdentity name="System.Text.Json" publicKeyToken="cc7b13ffcd2ddd51" culture="neutral" />
+ 
+              <bindingRedirect oldVersion="0.0.0.0-5.0.0.2" newVersion="5.0.0.2" />
+ 
+          </dependentAssembly>
+ 
+          <dependentAssembly>
+ 
+              <assemblyIdentity name="System.Text.Encodings.Web" publicKeyToken="cc7b13ffcd2ddd51" culture="neutral" />
+ 
+              <bindingRedirect oldVersion="0.0.0.0-5.0.0.1" newVersion="5.0.0.1" />
  
           </dependentAssembly>
  
diff --git a/UID/packages.config b/UID/packages.config
index 8194a9e..f7760d3 100644
--- a/UID/packages.config
+++ b/UID/packages.config
@@ -3,6 +3,7 @@
   <package id="ATAPI" version="2018.3.9" targetFramework="net47" />
   <package id="BCrypt.Net-Next" version="4.0.3" targetFramework="net47" requireReinstallation="true" />
   <package id="ClosedXML" version="0.95.4" targetFramework="net47" />
+  <package id="Confluent.Kafka" version="2.11.1" targetFramework="net48" />
   <package id="DocumentFormat.OpenXml" version="2.7.2" targetFramework="net47" />
   <package id="ExcelNumberFormat" version="1.0.10" targetFramework="net47" />
   <package id="Gcef.Data.DataEngine" version="3.0.2" targetFramework="net47" />
@@ -26,15 +27,16 @@
   <package id="GrapeCity.Documents.DX.Windows" version="4.2.0.722" targetFramework="net47" />
   <package id="GrapeCity.Documents.Imaging" version="4.2.0.722" targetFramework="net47" />
   <package id="Hardcodet.NotifyIcon.Wpf" version="1.0.5" targetFramework="net40-Client" requireReinstallation="True" />
+  <package id="librdkafka.redist" version="2.11.1" targetFramework="net48" />
   <package id="Microsoft.Bcl.AsyncInterfaces" version="5.0.0" targetFramework="net47" />
   <package id="Microsoft.CSharp" version="4.7.0" targetFramework="net47" />
   <package id="SSH.NET" version="2024.0.0" targetFramework="net47" />
-  <package id="System.Buffers" version="4.5.1" targetFramework="net47" />
+  <package id="System.Buffers" version="4.6.1" targetFramework="net48" />
   <package id="System.IO.FileSystem.Primitives" version="4.0.1" targetFramework="net47" />
   <package id="System.IO.Packaging" version="4.0.0" targetFramework="net47" />
-  <package id="System.Memory" version="4.5.4" targetFramework="net47" />
-  <package id="System.Numerics.Vectors" version="4.5.0" targetFramework="net47" />
-  <package id="System.Runtime.CompilerServices.Unsafe" version="5.0.0" targetFramework="net47" />
+  <package id="System.Memory" version="4.6.3" targetFramework="net48" />
+  <package id="System.Numerics.Vectors" version="4.6.1" targetFramework="net48" />
+  <package id="System.Runtime.CompilerServices.Unsafe" version="6.1.2" targetFramework="net48" />
   <package id="System.Text.Encodings.Web" version="5.0.1" targetFramework="net47" />
   <package id="System.Text.Json" version="5.0.2" targetFramework="net47" />
   <package id="System.Threading.Tasks.Extensions" version="4.5.4" targetFramework="net47" />
diff --git a/UID/usrctlProcedures.Designer.vb b/UID/usrctlProcedures.Designer.vb
index 6bdd199..11c10a3 100644
--- a/UID/usrctlProcedures.Designer.vb
+++ b/UID/usrctlProcedures.Designer.vb
@@ -139,6 +139,7 @@ Partial Class usrctlProcedures
         Me.Button43 = New System.Windows.Forms.Button()
         Me.DataGridViewTextBoxColumn1 = New System.Windows.Forms.DataGridViewTextBoxColumn()
         Me.DataGridViewTextBoxColumn2 = New System.Windows.Forms.DataGridViewTextBoxColumn()
+        Me.Button49 = New System.Windows.Forms.Button()
         Me.TabControl1.SuspendLayout()
         Me.TabPage3.SuspendLayout()
         Me.TabPage1.SuspendLayout()
@@ -1248,10 +1249,20 @@ Partial Class usrctlProcedures
         Me.DataGridViewTextBoxColumn2.HeaderText = "anz"
         Me.DataGridViewTextBoxColumn2.Name = "DataGridViewTextBoxColumn2"
         '
+        'Button49
+        '
+        Me.Button49.Location = New System.Drawing.Point(741, 654)
+        Me.Button49.Name = "Button49"
+        Me.Button49.Size = New System.Drawing.Size(75, 23)
+        Me.Button49.TabIndex = 66
+        Me.Button49.Text = "Kafka TEST"
+        Me.Button49.UseVisualStyleBackColor = True
+        '
         'usrctlProcedures
         '
         Me.AutoScaleDimensions = New System.Drawing.SizeF(6.0!, 13.0!)
         Me.AutoScaleMode = System.Windows.Forms.AutoScaleMode.Font
+        Me.Controls.Add(Me.Button49)
         Me.Controls.Add(Me.Button43)
         Me.Controls.Add(Me.Button33)
         Me.Controls.Add(Me.lblStatus)
@@ -1441,4 +1452,5 @@ Partial Class usrctlProcedures
     Friend WithEvents Button47 As Button
     Friend WithEvents Button48 As Button
     Friend WithEvents btnTC_FtpIUpload As Button
+    Friend WithEvents Button49 As Button
 End Class
diff --git a/UID/usrctlProcedures.vb b/UID/usrctlProcedures.vb
index 5412c90..0eae090 100644
--- a/UID/usrctlProcedures.vb
+++ b/UID/usrctlProcedures.vb
@@ -9,6 +9,7 @@ Imports System.Text
 Imports System.Xml
 Imports System.Xml.Serialization
 Imports Chilkat
+Imports Confluent.Kafka
 Imports GrapeCity
 Imports iTextSharp.text.pdf
 Imports Microsoft.Office.Interop
@@ -4016,6 +4017,29 @@ Public Class usrctlProcedures
 
     End Sub
 
+    Private Sub Button49_Click_1(sender As Object, e As EventArgs) Handles Button49.Click
+        Try
+            Dim mrn As String = "ATC400003850720243230"
+
+            ' Objekt
+            Dim rec = cATEZ_Greenpulse_KafkaDecsBuilder_DAKOSY.BuildByMrn(mrn)
+
+            '  Dim rec = cATEZ_Greenpulse_KafkaDecs.BuildDemo()
+            '' JSON (schön formatiert)
+            'Dim json As String = cATEZ_Greenpulse_KafkaDecsBuilder_DAKOSY.BuildJsonByMrn(mrn, pretty:=True)
+            'Console.WriteLine(json)
+
+
+            Dim key = cATEZ_Greenpulse_KafkaDecs.GetUniqueKey_Pipe("DE", "DAKOSY", mrn)
+            Dim dr = cATEZ_Greenpulse_KafkaDecs.InsertOrUpdateToKafkaSync(rec, key, 30000)
+
+            MessageBox.Show($"OK: {dr.Status} @ {dr.TopicPartitionOffset}")
+
+        Catch ex As Exception
+            MessageBox.Show(ex.Message)
+        End Try
+    End Sub
+
 
     'Private Sub Button26_Click(sender As Object, e As EventArgs)
     '    For Each d In System.IO.Directory.GetDirectories("\\192.168.0.91\Datenarchiv\DAKOSY\ECHTSYSTEM\Nachrichtendaten_Ablage\2019")