Saltar al contenido principal
Streaming Hub es el servicio de entrega de eventos de Lerian. Se sitúa en el borde entre el flujo de eventos interno de la plataforma y los sistemas que ejecutas fuera de ella, y entrega cada evento que te importa a un destino que tú controlas: un webhook, una cola en la nube o un cursor que consultas mediante pull. Los productos de Lerian publican eventos de dominio —hechos de negocio en tiempo pasado, como la creación de una cuenta o el registro de una transacción— en una red troncal de streaming compartida. Streaming Hub se suscribe a esa red troncal en tu nombre, hace coincidir los eventos con las suscripciones que registras y los entrega. Tú describes qué eventos van a dónde; el hub se encarga del ciclo de consumir, hacer coincidir y entregar. Streaming Hub es de código cerrado y está disponible para clientes de Lerian con licencia; su repositorio se mantiene de forma interna.

​
Streaming Hub en la plataforma Lerian

La red troncal de eventos de la plataforma es un flujo basado en CloudEvents compartido, transportado sobre Kafka/Redpanda y producido a través de la librería lib-streaming de Lerian. La entrega en ese flujo es at-least-once, los eventos de todos los productos y tenants viajan por los mismos tópicos, y consumirlo directamente significa ejecutar tu propio consumidor de Kafka: rastrear offsets, filtrar tipos de evento, deduplicar, reintentar entregas fallidas y firmar las solicitudes salientes. Streaming Hub hace ese trabajo una sola vez, como un borde gestionado. Consume el flujo interno —nunca produce sobre él— y convierte un feed de eventos en bruto en una entrega por destino que configuras a través de una única API. Tú registras una suscripción, el hub sigue el flujo y los eventos coincidentes llegan a tu endpoint ya firmados y correlacionados. Como el hub es el borde de entrega, las garantías sobre las que construyes son el contrato de entrega del hub, no el flujo en bruto: tu endpoint de webhook verifica una firma, deduplica por un id de evento estable y responde con rapidez. Consulta Cómo funciona Streaming Hub para ver el recorrido completo de un evento.

​
Tipos de sink

Una suscripción entrega a exactamente un destino, llamado sink. Streaming Hub admite cinco tipos de sink: Los sinks push (webhook, sqs, rabbitmq, eventbridge) te entregan los eventos a medida que coinciden. El sink pull invierte eso: el hub mantiene los eventos en un cursor y tu consumidor los obtiene según su propia planificación. Las suscripciones de webhook están listas para recibir en cuanto las creas. Las suscripciones de cola (sqs, rabbitmq, eventbridge) no entregan nada hasta que suministras y verificas su credencial saliente; consulta Gestión de suscripciones.

​
Modelo de despliegue

Streaming Hub se ejecuta en modo BYOC por defecto: lo despliegas en tu propia infraestructura como un servicio de un solo tenant, con un roster de tenants estático y sin dependencia de la gestión de tenants alojada por Lerian. Esta es la forma en que lo ejecutan la mayoría de los clientes. Un modo SaaS multi-tenant se encuentra detrás de un flag de configuración. Cuando está habilitado, el hub sirve a muchos tenants sobre el bus compartido, admite tenants desde un roster respaldado por caché que alimenta el tenant manager de Lerian, y aísla las suscripciones, los eventos y los cursores de cada tenant por su id de tenant. El camino BYOC no lleva nada de esa maquinaria. Consulta el modelo de multi-tenancy de toda la plataforma para ver cómo funciona el aislamiento de tenants entre los productos de Lerian, y Operación de Streaming Hub para los detalles de despliegue.

​
La API del plano de control

Gestionas las suscripciones a través de la API del plano de control /v1. Cada ruta se autentica con un JWT de plugin-auth (Authorization: Bearer <token>), y el tenant siempre se toma de los claims validados del token, nunca del body, la ruta o el query de una solicitud. A través de ella puedes:
  • crear, listar, leer y eliminar suscripciones;
  • verificar un destino (ping / verify) y suministrar credenciales de cola;
  • rotar el secreto de firma de un webhook;
  • leer la salud de entrega de una suscripción;
  • consultar eventos mediante pull (GET /v1/events) para los sinks pull;
  • explorar el catálogo de eventos que ve el hub.
El conjunto completo de operaciones, las formas de las solicitudes y los tokens de error están en la referencia de la API; empieza por la introducción a la referencia.

​
Próximos pasos

Cómo funciona Streaming Hub

El recorrido de un evento: ingesta, coincidencia, envío, reintento y auto-desactivación.

Gestión de suscripciones

Crea suscripciones de webhook y de cola, conecta concesiones de AWS y rota secretos.

Consumo de eventos

Verifica firmas de webhook, deduplica entregas y consulta eventos mediante pull.

Introducción al event streaming

El contrato compartido de CloudEvents que sigue cada evento de Lerian.