Antwortweg Kafka
Wichtiger Hinweis: Die Kafka-Unterstützung ist eine Beta-Version.
Einführung: Phase 6.
(1) Der Kafka-Alias. Siehe Abschnitt Kafka-Verbindungen.
(2) Das Topic, an das die Nachricht gesendet wird. Hinweis: Falls die System-Variable KAFKA_PARTITION des Typs Integer definiert ist und einen Wert >=0 hat, wird dieser als zu verwendende Partition des Topics übergeben.
(3) Der Daten-Typ der zu sendenden Daten der Nachricht. 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!
(4) Der Daten-Typ des Schlüssels der Nachricht. 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!
(5) Der (optionale) Schlüssel der Nachricht.
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!