> ## Documentation Index
> Fetch the complete documentation index at: https://docs.lerian.studio/llms.txt
> Use this file to discover all available pages before exploring further.

# Eventos do Lender

> Use os streams de aplicação v3 do Lender, os tipos CloudEvents qualificados por source, a entrega pelo outbox, o manifesto e o contrato de consumidor em runtime.

O Lender publica fatos de negócio e comandos como CloudEvents 1.0 sobre Kafka. A publicação é obrigatória, delimitada por tenant e apoiada em um outbox transacional.

## Configure a publicação

***

| Ajuste | Valor |
| - | - |
| `STREAMING_ENABLED` | `true` |
| `STREAMING_BROKERS` | Os seus brokers Kafka ou RedPanda. |
| `STREAMING_CLOUDEVENTS_SOURCE` | `lender`. A inicialização rejeita qualquer outro source. |

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.

| Elemento de transmissão | Valor |
| - | - |
| Tópico de fatos | `lerian.streaming.lender` |
| Tópico de comandos | `lerian.streaming.lender.commands` |
| `ce-source` | `lender` |
| `ce-type` | `studio.lerian.lender.<resource>.<event>` |
| Chave de despacho | `<resource>.<event>`, a partir de `ce-resourcetype` e `ce-eventtype` |
| Chave de partição | Identificador do tenant |

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.

Veja a [Referência de eventos do Lender](https://docs.lerian.studio/pt/reference/events/lender.md) para cada definição do catálogo e o `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](https://docs.lerian.studio/pt/products/lender/consignado-privado.md) 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

***

> [card] [Referência de eventos do Lender](https://docs.lerian.studio/pt/reference/events/lender.md)
>
> Inspecione contratos emitidos, apenas de catálogo e consumidos.

> [card] [Consignado privado](https://docs.lerian.studio/pt/products/lender/consignado-privado.md)
>
> Acompanhe o fluxo de comandos e fatos de folha de pagamento.


This documentation is built and hosted on [Mintlify](https://mintlify.com), a developer documentation platform.