Saltar al contenido

DEPT·F2 — TRANSPORTE Y TELEMETRÍA2026

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.

El encargo

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.

Qué se construyó

  1. Hexagonal por servicio: el gateway publica perfiles de tránsito (low/moderate/high/overload), el hub persiste de forma idempotente por event id.

  2. Regla de alerta fijada por tests: 3 DOWN consecutivos → exactamente 1 alerta por episodio.

  3. DLT con reintentos absorbe duplicados y JSON corrupto sin bloquear el carril.

  4. demo.sh demuestra el ciclo completo desde cero: recuentos idempotentes, una alerta, enrutado a DLT.

  5. 10/10 tareas entregadas con Spec-Driven Development; 3 ADRs; diagramas publicados automáticamente en GitHub Pages por CI.

Métricas

3×DOWN → 1alerta por episodio
100%inserciones idempotentes
10/10tareas SDD hechas

Impacto

El resultado es visibilidad operativa sobre ~90 adaptadores en 4 países: quién está DOWN, desde cuándo y exactamente una alerta por episodio — sin tormentas de pager ni huecos silenciosos.

STACK

Java 25Spring Boot 4.1KafkaOracleFlywayTestcontainersSSE
VISITA EL REPO

INFORME DE CALIDAD — MÉTRICAS SONAR

Volver a Transporte y Telemetría