How mgmmuthuganesh-ux/real-time-trade-streaming-platform works
This is a Spring Boot trade-event producer/consumer demo. A client submits a trade to the producer’s /trades endpoint; the controller passes the event to a Kafka producer, which publishes it to trade-events, where the consumer listener receives it. The consumer’s logged output is the demonstrated result; no persistence or downstream trade processing is shown. The consumer implementation was not excerpted, so its internal links rely on README statements and the repository tree; future enhancements are not represented as implemented capabilities.
Main entry points: TradeController.java Trade API · TradeProducer.java Trade Publisher · TradeConsumer.java Trade Listener · TradeEvent.java Trade Event
Components 9
Trade Ingress
- Producer App
trade-producer-service/src/main/java/com/trading/producer/TradeProducerServiceApplication.java - Trade API
trade-producer-service/src/main/java/com/trading/producer/controller/TradeController.java - Trade Event
trade-producer-service/src/main/java/com/trading/producer/model/TradeEvent.java
Kafka Stream
- Trade Publisher
trade-producer-service/src/main/java/com/trading/producer/service/TradeProducer.java - Kafka Broker
Trade Consumption
- Consumer App
trade-consumer-service/src/main/java/com/example/tradingconsumer/TradeConsumerServiceApplication.java - Trade Listener
trade-consumer-service/src/main/java/com/example/tradingconsumer/listener/TradeConsumer.java - Consumer Event Model
trade-consumer-service/src/main/java/com/example/tradingconsumer/Model/TradeEvent.java
Other components
- HTTP Client
Connections 7
- HTTP Client → Trade API: posts trade
README.md - Trade API → Trade Event: accepts payload
trade-producer-service/src/main/java/com/trading/producer/controller/TradeController.java - Trade API → Trade Publisher: calls publish
trade-producer-service/src/main/java/com/trading/producer/controller/TradeController.java - Trade Publisher → Trade Event: publishes event
trade-producer-service/src/main/java/com/trading/producer/service/TradeProducer.java - Trade Publisher → Kafka Broker: sends to topic
trade-producer-service/src/main/java/com/trading/producer/service/TradeProducer.java - Kafka Broker → Trade Listener: delivers events
README.md - Trade Listener → Consumer Event Model: deserializes event
README.md