Salta al contingut

DEPT·F2 — TRANSPORT I TELEMETRIA2026

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.

L’encàrrec

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.

Què es va construir

  1. Hexagonal per servei: el gateway publica perfils de trànsit (low/moderate/high/overload), el hub persisteix idempotentment per event id.

  2. Regla d’alerta fixada per tests: 3 DOWN consecutius → exactament 1 alerta per episodi.

  3. DLT amb reintents absorbeix duplicats i JSON corrupte sense bloquejar el carril.

  4. demo.sh demostra el cicle complet des de zero: recomptes idempotents, una alerta, encaminament a DLT.

  5. 10/10 tasques lliurades amb Spec-Driven Development; 3 ADRs; diagrames publicats automàticament a GitHub Pages per CI.

Mètriques

3×DOWN → 1alerta per episodi
100%insercions idempotents
10/10tasques SDD fetes

Impacte

El resultat és visibilitat operativa sobre ~90 adaptadors a 4 països: qui està DOWN, des de quan i exactament una alerta per episodi — sense tempestes de pager ni forats silenciosos.

STACK

Java 25Spring Boot 4.1KafkaOracleFlywayTestcontainersSSE
VISITA EL REPO

INFORME DE QUALITAT — MÈTRIQUES SONAR

Tornar a Transport i Telemetria