StreamPulse — eventos de comercio en tiempo real

Sobre el proyecto

Procesamiento de eventos con tiempo de evento, watermarks, deduplicación y DLQ: el pedido que llega tarde o duplicado no rompe las métricas.

Qué incluye

• Tiempo de evento con watermarks: lo tardío no rompe métricas
• Deduplicación de eventos repetidos
• DLQ: lo inválido se aparta sin frenar el pipeline

Cómo funciona

1. 1Eventos de comercio → ingesta por API
2. 2Watermarks y dedupe ordenan lo tardío y repetido
3. 3Agregados por ventana de tiempo de evento
4. 4Métricas consistentes al panel; errores a la DLQ