PRODUCERS
LIVE DEMO JAVA 21 · SPRING BOOT · KAFKA STREAMS
Reconcile the
event stream.
Build a payment and ledger transaction, publish it to Kafka, and inspect every acknowledged event, stream-processing decision, and auditable outcome.
01 / BUILD EVENTS
Create a transaction.
Control both sides of the transaction. Every submission is validated by Spring Boot and published as real Kafka records.
QUICK PRESETS
Or run a known case.
These shortcuts populate and publish repeatable event patterns.
Loading scenarios…
02 / STREAM TOPOLOGY
Follow the transaction.
Active
Review
BROKER
Apache Kafka
Partitioned by transactionSTREAM ENGINE
Join + deduplicate
10s window · 3s graceOUTCOME
Audit + exception topics
Queryable result projection
WAITING
The topology is ready for a scenario.
LIVE PROCESSING TRACE
What the system is doing.
-
01
Validate requestWAITING
Spring validates amounts, currencies, ordering, and event presence.
-
02
Construct event recordsWAITING
Immutable Java records receive event IDs, references, and event timestamps.
-
03
Broker acknowledgementWAITING
Idempotent producers write JSON records, keyed by transaction ID.
-
04
Stateful stream processingWAITING
Kafka Streams deduplicates event IDs and joins both sides in event time.
-
05
Classify outcomeWAITING
Domain rules compare event presence, amount, and currency.
-
06
Route and projectWAITING
The result reaches the audit topic, exception topic when needed, and this query view.
03 / RECONCILIATION
Latest outcome.
—
A reconciliation result will appear here after both sides of the event window are evaluated.
TRANSACTION
—
—
- Payment
- — No event
- Ledger
- — No event
04 / AUDIT STREAM
Recent transaction activity.
Transactions0
Matched0
Flagged0
Match rate—
| Evaluated | Transaction | Outcome | Payment | Ledger | Reason |
|---|---|---|---|---|---|
| No reconciliation events yet. | |||||