Einstellungen

(1) Max. Dateianzahl pro Übertragung: Hier kann die maximale Anzahl von Dateien, die pro Nachricht gesendet werden dürfen, angegeben werden. Das kann dazu führen, dass innerhalb einer ausgelösten Übertragung mehrere Nachrichten entstehen. Sie finden entsprechende Meldungen im ASM-Log ("... message 1", "... message 2", ...). Es werden aber pro ausgelöster Übertragung immer alle bis dahin gesammelten Dateien verarbeitet.

(2) Alias: Der Kafka-Alias. Siehe Abschnitt Kafka-Verbindungen.

(3) Topic: Das Topic, an das die Nachricht gesendet wird.

(4) Persist too large messages: Dies ist eine spezielle Einstellung, die Sie im Normalfall ignorieren können (und sollten). Wenn eine verschickte Nachricht zu groß ist (Broker-Limit 1 MB per Default, 10 MB Protokoll-Limit), kommt es normalerweise zu einer Exception. Wenn diese Checkbox gesetzt ist, dann wird diese Exception abgefangen, die Datei stattdessen in einem lokalen Ordner abgelegt und eine Dummy-Nachricht mit einem Verweis auf die lokale Datei versendet, mit der sich der Empfänger automatisch diese lokale Datei besorgt. Dies funktioniert momentan aber nur, wenn die Consumer, die auf das Topic (3) hören, sich im selben Load-Balancing-System befinden. Setzen Sie diese Checkbox ansonsten nicht, da dadurch der Eindruck entsteht, dass die Nachricht erfolgreich versendet wurde, aber der Empfänger diese nicht empfangen kann.

(5) Data Type: Der Datentyp der zu sendenden Daten der Nachricht. Wichtiger Hinweis: Der Datentyp 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! Wichtiger Hinweis: Wird der Datentyp AVRO verwendet, muss zusätzlich der Pfad zu einer Schema-Datei (6) und in (12) die Adresse zur Schema-Registry angegeben werden. Name: schema.registry.url , Wert: http://address:port.

(6) Path to schema file: Siehe (5).

(7) Key Type: Der Datentyp des Schlüssels der Nachricht. Wichtiger Hinweis: Der Datentyp 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!

(8) Wartezeit in ms: Die Wartezeit (linger.ms) ist die Zeit, die bis zum Senden gewartet wird. Wenn bis dahin noch Nachrichten dazukommen, werden alle zusammen verschickt. Bei 0 ms wird immer sofort einzeln geschickt und nie gewartet.

(9) Messagegröße in KB: Die Messagegröße (batch.size) bestimmt die Maximalgröße der gesammelten Nachrichten. Wird diese Größe vor dem Ablauf der Wartezeit erreicht, wird versendet.

(10) Abort on Error: Ist diese Checkbox nicht gesetzt, dann wird der Versand auch bei fehlerhaften Nachrichten nicht unterbrochen.

(11) Client-ID: Eine optionale ID eines Kafka-Consumers (in einer Consumer-Gruppe), die bei jeder Anforderung an einen Kafka-Broker übergeben wird.

(12) KafkaProducer Properties: Über das Kontextmenü können weitere Producer Properties definiert werden.