cbam kafka
This commit is contained in:
@@ -6,6 +6,7 @@
|
||||
Imports System.Data.SqlClient
|
||||
Imports System.Threading
|
||||
Imports System.Threading.Tasks
|
||||
Imports System.Windows.Forms
|
||||
Imports Confluent.Kafka
|
||||
|
||||
Imports Newtonsoft.Json
|
||||
@@ -271,9 +272,22 @@ Public Class cATEZ_Greenpulse_KafkaDecs
|
||||
End Function
|
||||
|
||||
|
||||
|
||||
'========================
|
||||
'== Kafka: Insert/Update (per Message-Key)
|
||||
'========================
|
||||
|
||||
Public Shared Function InsertOrUpdateToKafkaSync_Bool(rec As cATEZ_Greenpulse_KafkaDecs, unique_KEY As String, Optional waitMs As Integer = 30000) As Boolean
|
||||
Try
|
||||
Dim result = InsertOrUpdateToKafkaSync(rec, unique_KEY, waitMs)
|
||||
|
||||
Return True
|
||||
Catch ex As Exception
|
||||
MessageBox.Show("Fehler beim Senden an Kafka: " & ex.Message, "Fehler", MessageBoxButtons.OK, MessageBoxIcon.Error)
|
||||
Return False
|
||||
End Try
|
||||
|
||||
End Function
|
||||
Public Shared Function InsertOrUpdateToKafkaSync(rec As cATEZ_Greenpulse_KafkaDecs, unique_KEY As String, Optional waitMs As Integer = 30000) As DeliveryResult(Of String, String)
|
||||
|
||||
|
||||
@@ -290,7 +304,7 @@ Public Class cATEZ_Greenpulse_KafkaDecs
|
||||
|
||||
Using producer = New ProducerBuilder(Of String, String)(cfg).Build()
|
||||
Dim key = unique_KEY ' GetUniqueKey(rec)
|
||||
Dim msg = New Message(Of String, String) With {.key = key, .Value = rec.ToJson(False)}
|
||||
Dim msg = New Message(Of String, String) With {.Key = key, .Value = rec.ToJson(False)}
|
||||
|
||||
Dim done As New Threading.ManualResetEventSlim(False)
|
||||
Dim lastReport As DeliveryResult(Of String, String) = Nothing
|
||||
|
||||
Reference in New Issue
Block a user