plugin-br-pix-lerian. Streaming Hub entrega estos eventos a los sistemas de tu institución.
Cómo funciona la entrega
- Al menos una vez. El caso de uso graba el estado de negocio y el sobre del evento en la misma transacción, en un outbox; el relay del outbox es el único publisher del broker. Un evento puede llegar más de una vez, pero nunca se pierde una vez confirmado el cambio de estado.
- Dos caminos de consumo. Streaming Hub entrega cada evento coincidente a un sink tuyo — webhook HTTPS con firma HMAC, SQS, RabbitMQ o EventBridge — o tu consumidor se suscribe al tópico
lerian.streaming.plugin-br-pix-leriancon cualquier cliente Kafka. - Elimina duplicados. En el webhook, por el header
X-Lerian-Event-Id; en Kafka, por el par(ce-source, ce-id). - No dependas del orden de llegada. La clave del registro es
<ce-tenantid>:<subject>, lo que da afinidad de partición por tenant y agregado, no orden estricto. Ordena por el ciclo de vida y por los timestamps dentro de cada evento. - Despacha por
ce-type. El tipo esstudio.lerian.plugin-br-pix-lerian.<event-key>y el valor del registro es solo el payload (data), sin sobre. Ignora los tipos que no manejas: eventos nuevos aparecen sin aviso, en el mismo tópico. - Los valores monetarios llegan como string decimal; interprétalos como decimales, nunca como punto flotante binario. Los timestamps están en UTC.
2xx solo después de que la verificación pase y el evento esté persistido de tu lado. El paso a paso de verificación, la rotación del secreto y los headers X-Lerian-* están en Consumir eventos; la creación del sink está en Gestionar subscriptions.
Descubrimiento de schema
Cada componente productor sirve dos endpoints HTTP bajo su propio prefijo de ruta:
El manifiesto lista los eventos que el componente publica y apunta al documento JSON Schema de cada par
(eventKey, schemaVersion). Úsalo como contrato en tiempo de deploy, en lugar de adivinar tópicos y formatos. Los dos endpoints comparten un único grant de autorización, streaming-manifest/get, acotado al application name del componente (plugin-br-pix-lerian-spi, -dict, -cob, -pixauto); envía el token como Authorization: Bearer <token>. Las instalaciones con la autorización deshabilitada sirven los dos endpoints sin autenticación.
Lee
ce-schemaversion en cada registro y guarda en caché el documento de schema por el par (eventKey, schemaVersion). Los productores escriben registros solo en la versión vigente de cada evento; una versión reemplazada nunca se edita y su documento sigue servido para los consumidores aún fijados a ella.Catálogo
Todo
ce-type usa studio.lerian.plugin-br-pix-lerian.<event-key>. La lista autoritativa legible por máquina es el manifiesto de cada componente; las tablas de abajo son el mismo conjunto en prosa.