Kafka
Die evoVIU-Kamera unterstützt eine native Kafka Producer-Anbindung und ermöglicht damit die direkte Übertragung von Bilddaten, Metadaten oder Prüfergebnissen an ein Apache-Kafka-Cluster. Dies erlaubt die nahtlose Integration in moderne, skalierbare Datenarchitekturen und Streaming-Pipelines.
Über die Weboberfläche können Kafka-Broker (z. B. kafka01:9092) sowie das gewünschte Topic konfiguriert werden. Für eine strukturierte Verarbeitung lassen sich Daten im JSON-, Binär- oder Avro-Format senden. Die Auswahl des Formats hängt vom jeweiligen Anwendungsfall ab: JSON sorgt für eine einfache Lesbarkeit, wohingegen das Binär- und Avro-Format für effiziente Verarbeitung großer Bilddaten besser geeignet sind.
Der Versand kann zyklisch, ereignisgesteuert (z. B. bei OK/NOK-Ergebnissen) oder manuell ausgelöst werden. Dabei wird jede Nachricht mit einem Zeitstempel versehen. Bei Bedarf kann auch ein Schlüssel (key) für eine Partitionierung definiert werden.
Die Kafka-Anbindung ist besonders robust: Durch die Konfiguration von Acknowledgements, Retries und optionaler SASL/SSL-Verschlüsselung lässt sich eine zuverlässige, sichere Kommunikation sicherstellen.
Mit dieser Integration lässt sich die evoVIU flexibel in verteilte Systeme, Cloud-Infrastrukturen oder Analyseplattformen (z. B. Kafka Streams, Spark) einbinden – ideal für Industrie 4.0- oder IIoT-Szenarien.
Verbindungsparameter
Parameter | Type | Einheit | Erklärung | Beispiel | Required |
|---|---|---|---|---|---|
Bootstrap Server Uri | Domain || IP - String | Die Zieladresse des Kafka-Servers. | mykafka.myfacory.de |
| |
Port | Integer | Der Port der Kafka-Verbindung. | 9092 |
| |
ClientID | String | Die Client-ID ist ein eindeutiger Name zur Identifikation eines Kafka-Clients beim Broker. | 0 | ||
Retries | Integer | Anzahl der Sendeversuche bei Fehler einer Sendung. | 1 |
| |
Max In Flight Request per Connection | Integer | Legt fest, wie viele Anfragen parallel ohne Antwort gesendet werden dürfen. | 0 | ||
Message Max Bytes | Integer | Byte | Legt die maximale Größe einer Nachricht fest. Wert 0 = beliebig großes Message | 0 | |
Requests Timeout | Integer | ms | Legt die maximale Zeit fest, die der Client auf eine Antwort wartet. Wert 0 = beliebig lange Wartezeit | 0 | |
Local Timeout | Integer | ms | Legt das maximale Timeout für das Produzieren inklusive Retries fest. Wert 0 = beliebig lange Wartezeit | 0 | |
Allow Auto Create Topics | Bool | Erlaubt das automatische Erstellen von Topics beim Zugriff. | False | ||
Username | String | Der Username für die Authentifizierung. | Not used | ||
Passwort | String | Das Passwort für die Authentifizierung. | Not used | ||
SASL Mechanism | Dropdown | Legt das Auth-Verfahren fest. | None | ||
Security Protocol | Dropdown | Definiert das Verbindungsprotokoll. | None |
Workflow Setup
Anlage der Komponente Kafka Producer
Gehen Sie in Workflows unter Components auf ➕.
Suchen Sie nach der “Kafka Producer” Komponente und wählen Sie diese aus.
Es erscheint eine neue Komponente mit dem Namen “Kafka-Producer”. Diese kann jederzeit umbenannt werden.
Geben Sie die Verbindungsparameter ein.
Öffnen Sie in Ihrem Event Graph per Rechtsklick das Context-Menü.
Suchen Sie nach “Get Kafka Producer” und wählen Sie den Eintrag aus, damit der Node im Event Graph hinzugefügt wird.
Herzlichen Glückwunsch - Die Komponente “Kafka Producer” wurde erfolgreich angelegt.
Senden von Daten über Kafka Producer
Zunächst ist noch wichtig, die einzelnen Eingänge in dieser Komponente unabhängig von den Verbindungsdaten zu erklären:
Input | Erklärung | Beispiel |
|---|---|---|
Topic | Ein Topic ist ein logischer Kanal über den Nachrichten veröffentlicht und gelesen werden. |
|
Key | Der Key bestimmt die Partition einer Nachricht. Gleiche Keys landen immer in derselben Partition. |
|
Value | Der Value ist der eigentliche Nachrichtendateninhalt, den Producer senden und Consumer lesen. |
|
Suchen Sie im Context-Menü nach “Producer” und wählen Sie den Eintrag “Get Kafka Producer” aus.
Verbinden Sie den Output der Komponente “Get Kafka Producer” mit dem “Producer” Input des Produce-Knotens.
Geben Sie die jeweiligen Topic und Key-Werte an, die Ihnen bereitgelegt wurde. Gleichzeitig können Sie unter Value die entsprechenden Daten verlinken.
Herzlichen Glückwünsch! Sie können nun erfolgreich Daten an den Kafka Consumer senden.
Falls Sie sehen wollen, ob die Daten erfolgreich übertragen wurden, so können Sie am Ende des “Produce”-Knotens die Outputs “Success” und “Message” weiter verarbeiten und ausgeben lassen.
