Gruppe	Basic Functions

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_data 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_data 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_data immer UTF-8 als Encoding verwendet!