plugin-br-pix-lerian. Streaming Hub delivers these events to your institution’s systems.
How delivery works
- At least once. The use case writes the business state and the event envelope in the same transaction, into an outbox; the outbox relay is the only broker publisher. An event can arrive more than once, but it is never lost once the state change is committed.
- Two consumption paths. Streaming Hub delivers each matching event to a sink of yours — an HTTPS webhook with an HMAC signature, SQS, RabbitMQ, or EventBridge — or your consumer subscribes to the
lerian.streaming.plugin-br-pix-leriantopic with any Kafka client. - Deduplicate. On the webhook, by the
X-Lerian-Event-Idheader; on Kafka, by the(ce-source, ce-id)pair. - Do not rely on arrival order. The record key is
<ce-tenantid>:<subject>, which gives partition affinity per tenant and aggregate, not strict ordering. Order by the lifecycle and by the timestamps inside each event. - Dispatch on
ce-type. The type isstudio.lerian.plugin-br-pix-lerian.<event-key>and the record value is the payload alone (data), with no envelope. Ignore types you do not handle: new events appear without notice, on the same topic. - Monetary values arrive as decimal strings; interpret them as decimals, never as binary floating point. Timestamps are in UTC.
2xx only after the verification passes and the event is persisted on your side. The verification walkthrough, secret rotation, and the X-Lerian-* headers are in Consuming events; creating the sink is covered in Managing subscriptions.
Schema discovery
Each producing component serves two HTTP endpoints under its own route prefix:
The manifest lists the events the component publishes and points at the JSON Schema document for each
(eventKey, schemaVersion) pair. Use it as the deploy-time contract instead of guessing topics and formats. Both endpoints share a single authorization grant, streaming-manifest/get, scoped to the component’s application name (plugin-br-pix-lerian-spi, -dict, -cob, -pixauto); send the token as Authorization: Bearer <token>. Installations running with authorization disabled serve both endpoints unauthenticated.
Read
ce-schemaversion on each record and cache the schema document on the (eventKey, schemaVersion) pair. Producers write records at each event’s current version only; a superseded version is never edited and its document stays served for consumers still pinned to it.Catalog
Every
ce-type uses studio.lerian.plugin-br-pix-lerian.<event-key>. The authoritative machine-readable list is each component’s manifest; the tables below are the same set in prose.

