Don't miss the upcoming webinar: Building Real-Time Data Pipelines with a 3rd Generation Stream Processing Engine - sign up now!
Get it on Github

Real-Time Trade Processing

Tags:StreamingEvent SourcingWindowingEvent Time ProcessingEnrichmentAggregationIMDG StorageKafkaHBase SpringDAG API

Third party demo by Oliver Buckley-Salmon, Uses Jet 0.4

This demo shows how to use Hazelcast IMDG in an Event-Sourcing/CQRS architecture. Jet processes immutable events from an event bus (Kafka) to update storage optimized for querying and reading (IMDG).

Trades and prices are sourced into Jet from Kafka topics. Jet session windows and aggregations are used to group multiple trades and update positions. Updated values are stored in Hazelcast IMDG and written to HBase tables using MapStore.

DAG Visualization

Hazelcast Jet

Main Menu