Streaming & Ereignisse

Ein Ereignis darf nicht verloren gehen.

Eine Bestellung, ein Maschinenzustand oder eine Bestandsänderung soll weitere Abläufe auslösen. Wir entwerfen Ereignisverträge und implementieren die Plattform und Anbindungen, damit Empfänger zuverlässig reagieren können – auch bei Lastspitzen oder vorübergehenden Ausfällen.

Was wir übernehmen Vorhaben besprechen

Ereigniskatalog mit Schemata und Verantwortlichen · Planung und Umsetzung durch OTOKO®

Ihr Auftrag an OTOKO®

Was wir für Sie übernehmen.

Ein Ereignis beschreibt eine eingetretene Änderung; ein Befehl fordert eine Handlung an. Diese Unterscheidung hilft, Zuständigkeiten nicht zu vermischen. Wir definieren Kennungen, Zeitpunkt, Schema und benötigten Kontext. Die Reihenfolge wird für die fachlich relevante Einheit betrachtet, beispielsweise einen Auftrag, statt eine globale Reihenfolge pauschal zu versprechen. Bei Maschinenanbindung werden Protokolle, Netzgrenzen und zulässige Eingriffe mit den Betriebsverantwortlichen abgestimmt.

Der mögliche Leistungsumfang

Ereigniskatalog mit Schemata in AsyncAPI und Schema Registry
Aufbau von Kafka- oder RabbitMQ-Clustern mit Verschlüsselung, Zugriffskontrolle und Mandantentrennung
Anbindung von Quellen über Debezium, Kafka Connect und MQTT-Brücken für Maschinendaten
Verarbeitungsmuster für Reihenfolge, Idempotenz, Wiederholung und Event Sourcing
Betrieb mit Überwachung von Verzögerung, Durchsatz und Verbrauchergruppen

Den konkreten Umfang, Ihre Mitwirkung und die Abnahmekriterien legen wir vor Beginn fest.

Technik verständlich eingeordnet

So setzen wir die Aufgabe um.

Doppelte und verspätete Nachrichten einplanen

Wiederholte Zustellung kann nach Störungen auftreten. Verbraucher erhalten deshalb Regeln, wie sie bereits verarbeitete Ereignisse erkennen oder fachlich unschädlich wiederholen. Verspätete Ereignisse und nachträgliche Korrekturen werden getrennt berücksichtigt. Wir planen Aufbewahrung, Replay und Zugriffsschutz. Eine Ereignisplattform ist nicht automatisch ein unveränderliches Archiv; Aufbewahrungs- und Löschanforderungen müssen bewusst umgesetzt werden. Schemaänderungen werden auf Kompatibilität zu vorhandenen Verbrauchern geprüft.

Rückstände und Wiederaufholen testen

Die Abnahme umfasst einen ausfallenden Verbraucher, einen wachsenden Rückstand und den kontrollierten Neustart. Dashboards zeigen Verzögerung und Fehler, nicht nur die Anzahl eingegangener Nachrichten. Für den Einstieg benötigen wir Ereignisarten, erwartete Mengen, maximale Verzögerung und den fachlichen Umgang mit Reihenfolge oder Doppelverarbeitung.

Ein überprüfbares Ergebnis

Damit arbeiten Sie weiter.

Ereigniskatalog mit Schemata und Verantwortlichen
Betriebsfähige Ereignisplattform als Code
Verarbeitungsrichtlinie mit Mustern und Beispielen

Die Übergabe verbindet Umsetzung und Dokumentation. Gemeinsam prüfen wir die vereinbarten Fälle und halten verbleibende Aufgaben fest.

Ihr Vorhaben im Detail

Geschäftsereignisse zuverlässig verteilen und auswerten.

Wir entwickeln ereignisbasierte Verbindungen für Prozesse, die auf Änderungen reagieren sollen. Dabei planen wir nicht nur den Transport, sondern auch Bedeutung, Reihenfolge und erneute Verarbeitung der Ereignisse.

Ereignisse als fachliche Aussagen beschreiben

Ein Ereignis beschreibt, dass etwas stattgefunden hat, etwa eine bestätigte Bestellung. Wir vereinbaren Identifikator, Zeitpunkt, fachlichen Bezug und Versionsregeln. Konsumenten müssen erkennen können, ob sie dieselbe Nachricht bereits verarbeitet haben und ob ein Ereignis für ihren Zweck ausreichend Informationen enthält.

Reihenfolge ist häufig nur innerhalb eines bestimmten Geschäftsobjekts erforderlich. Diese Anforderung beeinflusst Partitionierung und Parallelität. Wir vermeiden pauschale Versprechen einer globalen Reihenfolge oder einmaligen fachlichen Verarbeitung und prüfen stattdessen die Garantien der gesamten Kette einschließlich Zielsystem.

Rückstau, Wiederholung und Datenaufbewahrung steuern

Ein langsamer Konsument darf nicht unbegrenzt unbemerkt zurückfallen. Wir überwachen Verzögerungen und planen, wie Kapazität erhöht oder Verarbeitung priorisiert wird. Fehlerhafte Nachrichten erhalten einen Klärungsweg, damit ein einzelner problematischer Datensatz nicht dauerhaft die gesamte Verarbeitung blockiert.

Wiederholbare Ereignisverarbeitung ist für Reparaturen und neue Konsumenten wertvoll, braucht aber Aufbewahrungs- und Datenschutzregeln. Wir legen fest, welche historischen Ereignisse verfügbar bleiben und wie ein Neuaufbau des Zielbestands erfolgt. Die Abnahme betrachtet ausdrücklich Unterbrechungen, doppelte Zustellung und den erneuten Start eines Konsumenten.

Illustratives Projektszenario

Wie die Leistung im Alltag hilft.

Beispiel: Ein bestätigter Auftrag löst Versandvorbereitung und eine Kundenbenachrichtigung aus. Beide Konsumenten verarbeiten unabhängig. Fällt die Benachrichtigung aus, bleibt der Auftrag erhalten; nach dem Wiederanlauf wird anhand der Vorgangskennung verhindert, dass dieselbe Mitteilung unkontrolliert mehrfach versendet wird.

Dieses Beispiel erläutert einen möglichen Ablauf und ist keine Kundenreferenz.

Vor dem ersten Schritt

Ihre Fragen zu Streaming & Ereignisse.

Garantiert ein Broker genau eine fachliche Verarbeitung?

Nicht allein. Zusicherungen der Plattform gelten innerhalb bestimmter Grenzen. Sobald externe Systeme geändert werden, muss die Anwendung Doppelverarbeitung und Wiederholungen passend behandeln.

Können Maschinendaten ohne direkten Zugriff auf die Produktion angebunden werden?

Oft sind Gateways oder vorhandene Exportwege möglich. Der konkrete Weg wird mit den Verantwortlichen für die Produktionsumgebung geprüft und freigegeben.

Ihr Vorhaben

Welche Aufgabe möchten Sie lösen?

Beschreiben Sie Ihre Ausgangslage und das gewünschte Ergebnis. Die ausgewählte Leistung wird in die Kontaktanfrage übernommen.

Diese Leistung anfragen

Menü

Ein Ereignis darf nicht verloren gehen.