Real-Time Trade Processing
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.