Configure a publicação
O Lender não inicia quando a publicação está desabilitada, quando nenhum broker está definido ou quando o source é inválido.
Contrato de transmissão
O Lender usa o contrato v3 de stream de aplicação. Um tópico identifica a aplicação produtora e a classe de mensagem, não um evento.
Por exemplo, um fato de desembolso trafega em
lerian.streaming.lender com ce-type: studio.lerian.lender.loan_application.disbursed.
ce-schemaversion carrega a versão do payload. O schema v2 não adiciona sufixo de tópico sob o contrato v3. Roteie pelos headers CloudEvents, não por um nome de tópico por evento.
Contrato publicado
O Lender emite 46 eventos: 45 fatos e um comando. Controles de funcionalidade governam cada caminho de integração, então consuma apenas os contratos expostos pelo manifesto em produção. O comando de catálogo é:
consignado.exclusao.requested: pede uma exclusão de consignado ao trilho de folha de pagamento.
ce-type qualificado por source dela.
Eventos que o Lender consome
O Lender conecta 15 chaves de fato voltadas ao gateway em
lerian.streaming.consignado-gw. As chaves incluem registro de contrato, confirmação de desembolso, rejeição de averbação, situação de emprego, conciliação, resultados de exclusão, disponibilidade de correção, resultados de portabilidade, resultados de refinanciamento, resultados de renegociação e resultados de migração. Os consumidores correspondentes são controlados por configuração. Portabilidade, refinanciamento, renegociação e migração usam, cada um, um flag opt-in para os resultados deles.
Em um refinanciamento, o Lender contabiliza o novo contrato apenas quando consignado.refinanciamento.efetivado traz novo_contrato. Sem esse bloco, o Lender mantém o fato em quarentena para intervenção operacional.
Um handler do Lender consome match_run.completed em lerian.streaming.matcher. Para a passagem padrão, o Matcher deve usar STREAMING_CLOUDEVENTS_SOURCE=matcher. O Lender roteia ce-source: matcher, ce-type: studio.lerian.matcher.match_run.completed, ce-resourcetype: match_run e ce-eventtype: completed. Se o Matcher usar outro source, inspecione o manifesto de streaming dele e alinhe os dois lados antes de habilitar os runtimes.
Veja Consignado privado para a jornada de folha de pagamento.
Durabilidade e entrega
O Lender grava cada evento de negócio de saída no outbox em PostgreSQL, na mesma transação de banco de dados da mudança de estado. Um relay publica o evento depois do commit. A entrega pelo broker é pelo menos uma vez: deduplique por
(ce-source, ce-id) e faça os handlers idempotentes.
O relay repete cada linha até OUTBOX_MAX_DISPATCH_ATTEMPTS vezes. O valor de OUTBOX_RETRY_WINDOW_SEC define a espera mínima entre tentativas para uma linha. É um atraso por tentativa, não uma janela total de novas tentativas. Os padrões são 10 tentativas e 300 segundos.
Convenções de payload
Os payloads são fatos JSON, não diffs. Valores de dinheiro e de taxa usam strings decimais em vez de números JSON. Os timestamps usam RFC 3339 em UTC. Leia
ce-schemaversion antes de decodificar um payload versionado.
Confira o contrato em produção
GET /api/v1/streaming/manifest retorna o catálogo em produção, os tópicos de aplicação, as versões de schema e as políticas de entrega. Ele exige um token bearer com streaming_manifest read.
Leia o manifesto quando o seu consumidor sobe e rejeite um source, uma chave de evento ou uma versão de schema inesperados antes de processar tráfego.
Próximos passos
Referência de eventos do Lender
Inspecione contratos emitidos, apenas de catálogo e consumidos.
Consignado privado
Acompanhe o fluxo de comandos e fatos de folha de pagamento.