Afeta
Equipes que produzem ou consomem streams de eventos do Fetcher, do Lender, do Matcher, do Midaz, do Reporter ou do Tracer.
O que mudou
Os produtores Kafka publicam em tópicos de aplicação documentados, como
lerian.streaming.ledger. Os consumidores se inscrevem nesses tópicos e roteiam os fatos individuais pelos headers do CloudEvents. O Reporter usa AMQP em vez disso: ele publica no exchange nomeado por RABBITMQ_REPORT_EVENTS_EXCHANGE e usa a chave de cada definição de evento como routing key. Os produtores validam os valores de source do seu roster, e os tipos do CloudEvents são qualificados pelo source.
O Matcher agora publica o tópico consumido pelo handoff de matcher habilitado do Lender. Os eventos do Reporter usam o source reporter; os manifestos deles carregam chaves de evento e não definem campos de tópico ou de dead-letter-topic por evento. Os consumidores do Reporter vinculam filas ao exchange configurado e roteiam pela chave de evento do manifesto.
Esta é uma correção da documentação de contratos implementados. Ela não anuncia um release de runtime.
Impacto
Classificação: Ação necessária. A derivação de tópico, a configuração de source, o roteamento de eventos ou o tratamento do manifesto do Reporter baseados no contrato anterior podem impedir a entrega ou rotear eventos de forma incorreta.
O que você precisa fazer
1
Os produtores Kafka publicam nos tópicos de aplicação documentados. Os consumidores Kafka se inscrevem nesses tópicos e roteiam os fatos pelos headers do CloudEvents. No Reporter, vincule uma fila a
RABBITMQ_REPORT_EVENTS_EXCHANGE e roteie pela chave de definição do evento.2
Defina o valor de source documentado de cada produtor e revise as suposições do consumidor sobre tipos de evento qualificados pelo source.
3
Revise as integrações do Matcher com o Lender e as do Reporter antes do próximo deploy de streaming.