Pular para o conteúdo principal
Streaming Hub é o serviço de entrega de eventos da Lerian. Ele fica na borda entre o stream interno de eventos da plataforma e os sistemas que você roda fora dela. Ele entrega cada evento que interessa a você para um destino seu: um webhook, uma fila na nuvem ou um cursor do qual você faz pull. Os produtos Lerian publicam eventos de domínio (fatos de negócio no passado, como uma conta criada ou uma transação lançada) em um backbone de streaming compartilhado. O Streaming Hub se inscreve nesse backbone em seu nome, compara os eventos com as subscriptions que você registra e os entrega. Você descreve quais eventos vão para onde. O hub é dono do ciclo de consumir, comparar e entregar.

​
O Streaming Hub na plataforma Lerian

O backbone de eventos da plataforma é um stream baseado em CloudEvents compartilhado, transportado em Kafka/Redpanda. A entrega nesse stream é pelo menos uma vez, e os eventos de cada tenant trafegam nos mesmos tópicos. Para consumi-lo diretamente, você deve rodar seu próprio consumidor Kafka. Esse consumidor controla offsets, filtra tipos de evento, deduplica, refaz entregas que falharam e assina requisições de saída. O Streaming Hub faz esse trabalho uma vez, como uma borda gerenciada. Ele consome o stream interno e nunca produz nele. Ele transforma um feed bruto de eventos em entrega por destino que você configura por uma única API. Como o hub é a borda de entrega, as garantias sobre as quais você constrói são o contrato de entrega do hub, não o stream bruto. Seu endpoint de webhook verifica uma assinatura, deduplica por um id de evento estável e responde rápido. Veja Como o Streaming Hub funciona para o caminho completo que um evento percorre.

​
Tipos de sink

Uma subscription entrega para exatamente um destino, chamado de sink. O Streaming Hub aceita cinco tipos de sink: Sinks push (webhook, sqs, rabbitmq, eventbridge) entregam eventos para você à medida que eles correspondem. O sink pull inverte isso: o hub mantém os eventos em um cursor e seu consumidor os busca no próprio ritmo. Uma subscription de webhook fica apta a receber entregas depois que uma sondagem assinada confirma que seu endpoint responde. Subscriptions de RabbitMQ exigem uma credencial de broker que o hub sonda antes da ativação. SQS e EventBridge podem ser ativados com uma credencial de saída que o hub sonda, ou com um grant delegado da AWS que não armazena credencial. Veja Gerenciar subscriptions.

​
Modelo de deploy

Em BYOC, a Lerian instala e atualiza o Streaming Hub na sua nuvem pelo Lifecycle Management. Lá ele roda como um serviço single-tenant, com um tenant de control plane configurado e sem dependência da gestão de tenants hospedada pela Lerian. Na Lerian Cloud, a Lerian opera o hub, e subscriptions, eventos e cursores ficam isolados por tenant.

​
A API de control plane

Você gerencia subscriptions pela API de control plane /v1. Cada rota exige um token do Access Manager (Authorization: Bearer <token>). O hub nunca pega o tenant de um corpo de requisição, caminho ou query. Por ela, você:
  • cria, lista, lê e exclui subscriptions.
  • verifica um destino (ping / verify) e fornece credenciais de fila.
  • rotaciona um segredo de assinatura de webhook.
  • lê a saúde de entrega de uma subscription.
  • lê o dashboard operacional das suas subscriptions.
  • faz pull de eventos (GET /v1/events) para sinks pull.
  • navega pelo catálogo de eventos que o hub enxerga.
O conjunto completo de operações, os formatos de requisição e os tokens de erro estão na referência da API. Comece pela introdução da referência.

​
Próximos passos

Como o Streaming Hub funciona

O caminho que um evento percorre: ingestão, correspondência, despacho, nova tentativa e desativação automática.

Gerenciar subscriptions

Crie subscriptions de webhook e de fila, conecte grants da AWS e rotacione segredos.

Consumir eventos

Verifique assinaturas de webhook, deduplique entregas e faça pull de eventos.

Visão geral do streaming de eventos

O contrato CloudEvents compartilhado que cada evento Lerian segue.