• Introduction
• Design
• Prerequisites
• Run
• References

This project is centered around the simulation of a stock market environment through the utilization of distributed systems and a message broker for seamless communication among different components of the system. In this simulation, producers generate synthetic stock price data as well as buy and sell orders, while consumers execute these orders and ensure the system stays up-to-date.

The system offers APIs that allow traders to list their orders, review their portfolio, and create new orders for buying or selling. Additionally, it provides APIs for accessing information on available stock instruments, including their last traded price and more.

As part of its design, the system incorporates observability features, enabling the tracking of various aspects within the system. This enhances transparency and facilitates in-depth analysis of its functioning.

Please note that this simulation is a simplified version and might not represent real-world trading conditions or all aspects of a complex stock market.

• Docker
• Docker Compose
• httpie
• make

mvn clean install

Start docker containers:

make start-docker

Start Java apps:

make start-apps

With all services up, access:

Generate traffic:

make traffic

Stop apps:

make stop-apps

Stop docker containers:

make stop-docker

Design:

  flowchart LR
    script[Script]
    as[Auth Server]
    ts[Ticker Server]
    os[Order Server]
    r[Redis]
    db[Database]
    k[Kafka]
    p[Producer]
    c[Consumer]
    script -->|Calls API| ts;
    script -->|Calls API| os;
    ts --> as;
    os --> as;
    r --> ts;
    os --> k
    ts --> db;
    os --> db;
    p -->|Generate synthetic Orders| k;
    k -->|Consumes Orders| c;
    r -->|Instrument price lookup| c;

Spring Admin:

Service Registry:

Service Registry:

Service Details via Service Registry:

Service Logs via Service Registry:

Central Dashboard - Service Logs:

Central Dashboard - Stats of HTTP Requests (Latency/Throughput):

Sample Exemplar:

Sample Trace:

Sample Logs for a Trace:

Service Graph for a Trace:

Full Service Graph:

• Filter by URLs of a selected service/application on HTTP Stats Grafana Dashboard
• Instrumentation of Redis APIs
• Instrumentation of consumer
• Traffic via API gateway by applying auth filters

• https://www.youtube.com/watch?v=fh3VbrPvAjg&ab_channel=SpringI%2FO
• https://spring.io/guides/tutorials/metrics-and-tracing/
• https://stackoverflow.com/questions/76418005/not-able-to-trace-database-requests-with-spring-boot-3-and-micrometer
• https://github.com/micrometer-metrics/micrometer-samples/blob/main/micrometer-samples-boot3-database/src/main/java/io/micrometer/boot3/samples/db/SampleController.java
• https://docs.spring.io/spring-boot/docs/current/reference/html/actuator.html
• https://www.confluent.io/blog/monitor-kafka-clusters-with-prometheus-grafana-and-confluent/