Seminar Lobster_data – IoT- und Event-Integration mit MQTT, Kafka und OPC UA

Die Schulung behandelt ereignis- und nachrichtenorientierte Integrationen mit Lobster_data. MQTT, Kafka und OPC UA werden anhand ihrer Kommunikationsmodelle, Zustellgarantien, Datenstrukturen und Betriebsanforderungen verglichen. Ziel ist eine belastbare Verbindung von Geräten, Brokern, Produktionssystemen und Unternehmensanwendungen.

Inhaltsverzeichnis

1. Lernziele
2. Seminarinhalte
3. Praxisübungen
4. Einordnung in den Lernpfad

Lernziele

• MQTT, Kafka und OPC UA nach Kommunikationsmodell und Einsatzgebiet sicher unterscheiden.
• Ereignisse, Topics, Metadaten und Nutzdaten in wartbare Integrationsmodelle überführen.
• Zustellung, Reihenfolge, Wiederholung und Skalierung technisch korrekt berücksichtigen.
• OT-/IT-Datenflüsse mit Sicherheit, Monitoring und kontrollierter Fehlerbehandlung betreiben.

Seminarinhalte

Tag 1: Ereignismodelle und Konnektivität

1. Schritt 1: Geräte-, Anlagen- und Geschäftsevents nach Quelle, Frequenz, Kritikalität, Reihenfolge und Aufbewahrung klassifizieren.
2. Schritt 2: MQTT-Broker, Topics, QoS, Retain-Verhalten und Sitzungen für Telemetrie- und Steuerungsfälle einordnen.
3. Schritt 3: Kafka-Topics, Partitionen, Consumer-Gruppen, Offsets und Wiederholung für skalierbare Ereignisströme verstehen.
4. Schritt 4: OPC-UA-Endpunkte, Knoten, Werte, Zeitstempel und Qualitätsinformationen für industrielle Daten erfassen.
5. Schritt 5: Verbindungen, Zertifikate, technische Identitäten und Netzwerkgrenzen in Lobster_data konfigurieren.
6. Schritt 6: Ein kanonisches Ereignismodell entwerfen, das Quelle, Zeitpunkt, Qualität, Schlüssel und Nutzdaten sauber trennt.

Tag 2: Verarbeitung, Resilienz und Betrieb

1. Schritt 1: Eingehende Events filtern, normalisieren, anreichern und nach Inhalt oder Quelle routen.
2. Schritt 2: Reihenfolge, Dubletten, verspätete Ereignisse und erneut zugestellte Nachrichten mit geeigneten Schlüsseln behandeln.
3. Schritt 3: Batching, Pufferung und Drosselung so konfigurieren, dass Zielsysteme vor Lastspitzen geschützt werden.
4. Schritt 4: Temporäre Broker-, Netzwerk- und Zielausfälle mit Wiederholung, Quarantäne und kontrolliertem Nachlauf absichern.
5. Schritt 5: Durchsatz, Rückstände, Latenz und Fehlerraten als betriebliche Kennzahlen überwachen.
6. Schritt 6: Eine End-to-End-Strecke von einem Ereignisbroker über Lobster_data bis zu Datenbank oder API aufbauen und unter Störung testen.

Praxisübungen

Konfiguration eines MQTT- oder Kafka-Eingangs; Normalisierung von Telemetriedaten; Routing und Batching; Simulation von Dubletten und Verbindungsabbrüchen; Aufbau einer überwachten Event-to-API- oder Event-to-Database-Strecke.

Einordnung in den Lernpfad

Vorher werden Integrationsprofile und Datenformate empfohlen. Für mehrstufige Geschäftsprozesse ergänzt Orchestrierung die ereignisorientierte Integration.