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 (Konfiguration/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!
Typ “Avro” und “Avro_apicurio”:
Geben Sie den Pfad zu Ihrer Schemadatei im Feld “Pfad zur Schemadatei“ an. Wählen Sie einen HTTP-Kanal in Feld “Schema Registry Kanal” aus. Verwendete Werte aus Kanal: “Partner Adresse” (für Feld “Schema Registry URL”), “Eigene Kennung”, “Eigenes Kennwort”. Ein Wert in Feld “Schema Registry URL” überschreibt den Kanal-Wert. Consumer Properties in (11) überschreiben die Kanalwerte auch.
Eine gesetzte Checkbox “Schema automatisch registrieren“ registriert das Schema automatisch auf dem Schema-Registrierungsserver. Führen Sie diesen Schritt nur aus, wenn Sie sicher sind, dass die angegebene Schemadatei korrekt ist und Sie diese Änderung wünschen.
(6) 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!
(7) 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.
(8) 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.
(9) Abort on Error: Ist diese Checkbox nicht gesetzt, dann wird der Versand auch bei fehlerhaften Nachrichten nicht unterbrochen.
(10) Client-ID: Eine optionale ID eines Kafka-Consumers (in einer Consumer-Gruppe), die bei jeder Anforderung an einen Kafka-Broker übergeben wird.
(11) KafkaProducer Properties: Über das Kontextmenü können weitere Producer Properties definiert werden.