¿Qué es Streaming Hub?

Streaming Hub es el servicio de entrega de eventos de Lerian. Se ubica en el borde entre el stream interno de eventos de la plataforma y los sistemas que ejecutas fuera de ella. Entrega cada evento que te interesa a un destino propio: un webhook, una cola en la nube o un cursor que consultas. Los productos de Lerian publican eventos de dominio (hechos de negocio en pasado, como la creación de una cuenta o el registro de una transacción) en un backbone de streaming compartido. Streaming Hub se suscribe a ese backbone 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 es responsable del ciclo de consumo, coincidencia y entrega.

​

Streaming Hub en la plataforma de Lerian

---

El backbone de eventos de la plataforma es un stream compartido basado en CloudEvents transportado sobre Kafka/Redpanda. La entrega en ese stream es al menos una vez, y los eventos de cada tenant viajan por los mismos temas. Para consumirlo directamente, debes ejecutar tu propio consumidor de Kafka. Ese consumidor sigue los offsets, filtra tipos de evento, deduplica, reintenta entregas fallidas y firma las solicitudes salientes. Streaming Hub hace ese trabajo una sola vez, como un borde gestionado. Consume el stream interno y nunca produce en él. Convierte un feed de eventos en bruto en entregas por destino que configuras mediante una sola API. Como el hub es el borde de entrega, las garantías sobre las que construyes son el contrato de entrega del hub, no el stream en bruto. Tu endpoint de webhook verifica una firma, deduplica con un id de evento estable y responde rápido. 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 programación. Una suscripción de webhook queda apta para entrega después de que una prueba firmada confirma que tu endpoint responde. Las suscripciones de RabbitMQ requieren una credencial de broker que el hub prueba antes de la activación. SQS y EventBridge pueden activarse con una credencial saliente que el hub prueba, o con una concesión delegada de AWS que no guarda ninguna credencial. Consulta Gestión de suscripciones.

​

Modelo de despliegue

---

En BYOC, Lerian instala y actualiza Streaming Hub en tu nube a través de Lifecycle Management. Allí funciona como un servicio single-tenant, con un tenant de plano de control configurado y sin dependencia de una gestión de tenants alojada por Lerian. En Lerian Cloud, Lerian opera el hub, y las suscripciones, los eventos y los cursores permanecen aislados por tenant.

​

La API de plano de control

---

Gestionas las suscripciones a través de la API de plano de control /v1. Cada ruta exige un token de Access Manager (Authorization: Bearer <token>). El hub nunca toma el tenant del cuerpo, la ruta o la query de la solicitud. A través de ella puedes:

• crear, listar, leer y eliminar suscripciones.
• verificar un destino (ping / verify) y proveer credenciales de cola.
• rotar el secreto de firma de un webhook.
• leer la salud de entrega de una suscripción.
• leer el dashboard operativo de tus suscripciones.
• extraer eventos (GET /v1/events) para 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 API. Empieza por la introducción a la referencia.

​

Próximos pasos

---