Event-Driven Architecture

Einfach erklärt

In traditionellen Architekturen ruft Service A direkt Service B auf: „Verarbeite diese Bestellung.” Service A wartet, bis B antwortet. Das ist einfach, aber problematisch: Wenn B langsam ist, ist A langsam. Wenn B ausfällt, fällt A aus.

Event-Driven Architecture dreht das um: Service A sendet ein Event – „Bestellung aufgegeben” – und macht sofort weiter. Service B, C und D hören auf dieses Event und reagieren unabhängig voneinander. A weiß nicht einmal, dass B, C und D existieren.

Synchron vs. Asynchron:

Aspekt	Request-Response	Event-Driven
Kopplung	Eng (A kennt B)	Lose (A kennt nur Event)
Timing	Synchron (warten)	Asynchron (fire & forget)
Skalierung	Gemeinsam	Unabhängig pro Consumer
Debugging	Einfach	Komplex (verteilt)

Technischer Deep Dive

Event-Struktur

{
  "eventId": "evt_01HX...",
  "eventType": "document.uploaded",
  "timestamp": "2026-02-19T18:00:00Z",
  "source": "upload-service",
  "data": {
    "documentId": "doc_123",
    "userId": "usr_456",
    "filename": "report.pdf",
    "sizeBytes": 204800
  }
}

KI-Pipeline mit Events

Upload Service  →  [document.uploaded]  →  Chunking Service
                                        →  Virus Scanner
                                        →  Audit Logger

Chunking Service →  [document.chunked]  →  Embedding Service

Embedding Service → [embeddings.created] → Vector DB Service
                                         → Search Index Service

Python-Beispiel mit Kafka

from kafka import KafkaProducer, KafkaConsumer
import json

# Producer: Event senden
producer = KafkaProducer(bootstrap_servers='kafka:9092')
producer.send('document.uploaded', json.dumps({
    "documentId": "doc_123",
    "filename": "report.pdf"
}).encode())

# Consumer: Event verarbeiten
consumer = KafkaConsumer('document.uploaded', bootstrap_servers='kafka:9092')
for message in consumer:
    event = json.loads(message.value)
    chunk_document(event['documentId'])