Der “kafka”-Konnektor ermöglicht die Weiterleitung von Datenpunkten an einen Apache Kafka-Cluster. Er wird als Konnektorschritt in einem Integrationsflow verwendet und kann Zustandsänderungen eines Digitalen Zwillings für die weitere Verarbeitung oder Speicherung an den Cluster senden.

Details zur Funktion:

• Authentifizierung: Optional — SASL PLAIN (Benutzername/Passwort); optional TLS/SSL (boolesch)
• Nachrichtenformat: Jede Nachricht enthält einen zufällig erzeugten UUID-Schlüssel, die Payload als String-Wert sowie den festen Header origin: niotix
• Bestätigungsmodus (acks): Standard -1 (alle In-Sync-Replicas müssen bestätigen)
• Publish-Timeout: Standard 30.000 ms
• Verbindungs-Timeout: 500 ms; bei Fehler 2 Wiederholungsversuche (Initial Retry Time: 100 ms)
• Topic: Wird je Nachricht im Integrationsflow definiert — Topics müssen im Kafka-Cluster vorab angelegt sein

Einstellungen

• Instanz-Name: Individueller, einfach zu erschließender Name des Konnektors.
• Beschreibung: Kurze Beschreibung.
• Broker: Adresse und Port des Kafka-Brokers (kommagetrennt für mehrere Broker, Format: host:port).
• Client ID: Client-ID, mit der sich niotix am Kafka-Cluster identifiziert.
• SSL: Optional. Aktiviert TLS-Verschlüsselung für die Verbindung zum Broker.
• SASL Mechanism: Optional. Authentifizierungsmethode; aktuell wird plain unterstützt.
• SASL User: Benutzername für die SASL-Authentifizierung.
• SASL Password: Passwort für die SASL-Authentifizierung.