kafka

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")