2026 · jordimarsal/kafka-adapter-telemetry

kafka-adapter-telemetry

Telemetria d'adaptadors dirigida per esdeveniments: pipeline Kafka gateway + hub amb persistència idempotent a Oracle, salut per adaptador, alertes i dashboard de missió en viu via SSE.

Problema

Una flota de ~90 adaptadors d'API a 4 països necessita visibilitat operativa: qui està DOWN, des de quan i què ha alertat ja. Construït com a estudi personal del problema de telemetria d'Open Gateway, de punta a punta.

Punts clau

• Hexagonal per servei: el gateway publica perfils de trànsit (low/moderate/high/overload), el hub persisteix idempotentment per event id.
• Regla d'alerta fixada per tests: 3 DOWN consecutius → exactament 1 alerta per episodi.
• DLT amb reintents absorbeix duplicats i JSON corrupte sense bloquejar el carril.
• demo.sh demostra el cicle complet des de zero: recomptes idempotents, una alerta, encaminament a DLT.
• 10/10 tasques lliurades amb Spec-Driven Development; 3 ADRs; diagrames publicats automàticament a GitHub Pages per CI.

Stack

• Java 25
• Spring Boot 4.1
• Kafka
• Oracle
• Flyway
• Testcontainers
• SSE

Mètriques

3×DOWN → 1

alert per episode

100%

idempotent inserts

10/10

SDD tasks done