send Kafka message(a,b,c,d,e,f,g)


Wichtiger Hinweis: Die Kafka-Unterstützung ist eine Beta-Version.

Mit dieser Funktion können Nachrichten an Kafka-Broker geschickt werden.

Parameterbeschreibung


Parameter

Beschreibung

a

Der Kafka-Alias.

b

Das Kafka-Topic, an das gesendet werden soll.

c

Der (optionale) Key der zu sendenden Nachricht.

d

Die Daten der zu sendenden Nachricht.

e

Der Daten-Typ des Keys. Hinweis: Verwenden Sie zur Auswahl eines Wertes die drei Punkte. Wichtiger Hinweis: Der Daten-Typ muss immer angegeben werden. Achten Sie darauf, dass Sie beim Senden und Empfangen immer übereinstimmende Typen verwenden. Wird z. B. eine Nachricht als Byte/String definiert und gesendet und dann als Integer/Byte gelesen, führt das zu einem Fehler und die Nachricht kann nicht gelesen werden. Lobster Integration als Consumer ist so lange blockiert, bis jemand diese falsche Nachricht vom Broker entfernt und verarbeitet so lange keine Nachrichten von diesem Topic!

f

Der Daten-Typ der Daten. Hinweis: Verwenden Sie zur Auswahl eines Wertes die drei Punkte. Wichtiger Hinweis: Der Daten-Typ muss immer angegeben werden. Achten Sie darauf, dass Sie beim Senden und Empfangen immer übereinstimmende Typen verwenden. Wird z. B. eine Nachricht als Byte/String definiert und gesendet und dann als Integer/Byte gelesen, führt das zu einem Fehler und die Nachricht kann nicht gelesen werden. Lobster Integration als Consumer ist so lange blockiert, bis jemand diese falsche Nachricht vom Broker entfernt und verarbeitet so lange keine Nachrichten von diesem Topic!

g

Das Encoding, falls ein Byte-Array verwendet wird (Daten-Typ). Hinweis: Verwenden Sie zur Auswahl eines Wertes die drei Punkte.

Header-Properties


Sie können mit System-Variablen der Form KAFKA_<Keyname> Header-Properties übergeben. Hinweis: Da man als Value für eine Header-Property nur Byte-Arrays angeben kann, wird in Lobster Integration immer UTF-8 als Encoding verwendet!