Activar la publicación
La originación sigue funcionando cuando la publicación está deshabilitada. Cuando la publicación está habilitada, Lender falla al arrancar si la configuración del broker o de la fuente es inválida.
Contrato de cable
Lender usa el contrato de stream de aplicación v3. Un tema identifica la aplicación productora y la clase de mensaje, no un evento.
Por ejemplo, un hecho de desembolso viaja en
lerian.streaming.lender con ce-type: studio.lerian.lender.loan_application.disbursed.
ce-schemaversion lleva la versión del payload. El esquema v2 no agrega un sufijo de tema bajo el contrato v3. Enruta por los headers de CloudEvents, no por un nombre de tema por evento.
Contrato publicado
El manifiesto declara 35 definiciones: 33 hechos y dos comandos. Los feature gates controlan rutas de integración individuales, así que consume solo los contratos que expone el manifiesto desplegado. Los dos comandos del catálogo son:
consignado.exclusao.requested: pide una exclusión de consignado al riel de nómina.consignado.redirecionamento.requested: pide un redireccionamiento de consignado al riel de nómina.
ce-type calificado por fuente.
Eventos que consume Lender
Lender conecta 15 claves de hechos orientadas al gateway desde
lerian.streaming.consignado-gw. Las claves incluyen registro de contrato, confirmación de desembolso, rechazo de averbação, situación laboral, resultados de redireccionamiento, conciliación, resultados de exclusión, disponibilidad de corrección, resultados de portabilidad y resultados de refinanciamiento. Los consumidores correspondientes dependen de la configuración. La portabilidad y el refinanciamiento usan cada uno un flag de activación explícita para su par de resultados.
El gateway tiene rutas de emisión para las primeras 13 claves. El par de portabilidad llega a Lender solo cuando su consumidor de resultados está habilitado y el manifiesto desplegado del gateway declara el evento. El manifiesto no declara los dos resultados de refinanciamiento, así que esos dos listeners no reciben tráfico vivo del runtime actual del gateway.
Un handler de Lender consume match_run.completed desde lerian.streaming.matcher. Para el traspaso predeterminado, Matcher debe usar STREAMING_CLOUDEVENTS_SOURCE=matcher. Lender enruta ce-source: matcher, ce-type: studio.lerian.matcher.match_run.completed, ce-resourcetype: match_run y ce-eventtype: completed. Si Matcher usa otra fuente, inspecciona su manifiesto de streaming y alinea ambos lados antes de habilitar los runtimes.
Consulta Consignado privado para el recorrido de nómina.
Durabilidad y entrega
Lender escribe cada evento de negocio saliente en el outbox de PostgreSQL, dentro de la misma transacción de base de datos que el cambio de estado. Un relay lo publica después del commit. La entrega del broker es al menos una vez: deduplica por
(ce-source, ce-id) y haz que los handlers sean idempotentes.
El relay reintenta cada fila hasta OUTBOX_MAX_DISPATCH_ATTEMPTS veces. El valor OUTBOX_RETRY_WINDOW_SEC define la espera mínima entre intentos para una fila. Es un retraso por intento, no una ventana total de reintentos. Los valores predeterminados son 10 intentos y 300 segundos.
Convenciones de payload
Los payloads son hechos JSON, no diffs. Los valores de dinero y de tasa usan cadenas decimales en lugar de números JSON. Las marcas de tiempo usan RFC 3339 UTC. Lee
ce-schemaversion antes de decodificar un payload versionado.
Verificar el contrato desplegado
GET /api/v1/streaming/manifest devuelve el catálogo desplegado, los temas de aplicación, las versiones de esquema y las políticas de entrega. Requiere un Bearer token con streaming_manifest read.
Lee el manifiesto cuando arranca tu consumidor y rechaza una fuente, una clave de evento o una versión de esquema inesperada antes de procesar tráfico.
Próximos pasos
Referencia de eventos de Lender
Inspecciona los contratos emitidos, los de solo catálogo y los consumidos.
Consignado privado
Sigue el flujo de comandos y hechos de nómina.