Kinesis es una herramienta de AWS que obedece al patrón consumer-producer-subscriber, es un patrón orientado a eventos donde existe un producer que inyecta eventos en un canal (data-stream) y un consumidor suscrito a ese canal. Cada evento inyectado en el data-stream de Kinesis es replicado a cada uno de los consumidores suscritos a ese stream, lo que permite implementar una arquitectura event driven donde cada consumidor procesa el evento y hace su parte con el mismo.

SPIN

Existen varios data-streams clasificados por funcionalidad: Por ejemplo:

  • payment-transaction-stream – Eventos generados por flujos transaccionales o que tienen que ver con transacciones.

  • enrollment-transaction-stream - Eventos relacionados al alta de cuentas Spin.

  • spei-execution-stream - Eventos relacionados al sistema SPEI.

Los eventos de Kinesis son JSONs mapeados en código a un POJO Java y viven en el repositorio spin-event-governance. Cualquier cambio o evento nuevo que se requiera debe hacerse vía una PR en ese repositorio y solicitando code review del equipo de Escorpión.