Event bus and streaming platform
Jarian is Niadad's event bus and streaming platform that captures, routes and replays events across systems in real time.
- Integration
- Niadad
- In development
Problem
Important changes (a transaction, a customer status update, a sensor reading) stay inside the source system, and others learn of them late through periodic polling. Data reaches analytics hours behind, and real-time reaction is impossible.
Platform overview
Jarian is Niadad's event-driven backbone: every system publishes its events, and consumers, from Darya to Bina and Bidar, subscribe independently. Events are kept with a defined schema and can be replayed from the beginning, so a new consumer or a data rebuild is always possible.
Key capabilities
Publish and subscribe
Decouples producers and consumers through named topics.
Durable log and replay
Stores events with configurable retention and allows replay from any point.
Schema registry
Versions the structure of every event so changes do not break consumers.
Stream processing
Filtering, enrichment, windowed aggregation and pattern detection on event streams.
Ingestion from sensors and devices
Receives IoT data over lightweight protocols and normalises it into standard streams.
Connectors
Ready-made connectors for databases (CDC), Darya, target systems and APIs.
Architecture
Event broker with distributed log
Schema registry and event contracts
Stream-processing engine
Device gateway and IoT protocols
Source and sink connectors
Stream monitoring and consumer lag
Integrations
Use cases
Related platforms
Solutions
Related insights
Let's build together.
If your organisation, bank or industry is ready to turn data into decisions, start the conversation here.