2026 · jordimarsal/kafka-adapter-telemetry

kafka-adapter-telemetry

Telemetría de adaptadores dirigida por eventos: pipeline Kafka gateway + hub con persistencia idempotente en Oracle, salud por adaptador, alertas y dashboard de misión en vivo vía SSE.

Problema

Una flota de ~90 adaptadores de API en 4 países necesita visibilidad operativa: quién está DOWN, desde cuándo y qué ha alertado ya. Construido como estudio personal del problema de telemetría de Open Gateway, de punta a punta.

Puntos clave

• Hexagonal por servicio: el gateway publica perfiles de tránsito (low/moderate/high/overload), el hub persiste de forma idempotente por event id.
• Regla de alerta fijada por tests: 3 DOWN consecutivos → exactamente 1 alerta por episodio.
• DLT con reintentos absorbe duplicados y JSON corrupto sin bloquear el carril.
• demo.sh demuestra el ciclo completo desde cero: recuentos idempotentes, una alerta, enrutado a DLT.
• 10/10 tareas entregadas con Spec-Driven Development; 3 ADRs; diagramas publicados automáticamente en GitHub Pages por CI.

Stack

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

Métricas

3×DOWN → 1

alert per episode

100%

idempotent inserts

10/10

SDD tasks done