🧠 Real-Time Stock Trading and Analytics Platform

A full-stack real-time trading application built using modern frontend technologies, big data tools, and a scalable backend database.

---

📌 Project Modules

• frontend/ -- Built with Next.js, Tailwind CSS, real-time charts, and secure auth.

• kafka-pipeline/ -- Streams live stock data using Kafka, Spark, and Alpha Vantage API.

• CassandraJavaConnection/ -- Java backend using Cassandra for transactions and history.

• Trading Matchmaking Algorithm/ -- Implements core order-matching logic in Java.

---

📁 Repository Structure

trading-webapp/
├── CassandraJavaConnection/        # Java backend using Cassandra DB
├── frontend/                       # Next.js + Tailwind frontend
├── kafka-pipeline/                 # Kafka + Spark based data stream
└── Trading Matchmaking Algorithm/  # Java-based trading engine (matching logic)

---

💻 Frontend -- Next.js + Tailwind

A modern trading platform frontend built with Next.js and Tailwind CSS, featuring real-time data visualization and responsive design.

🚀 Features

• 📈 Real-time market data with WebSocket integration

• 📱 Fully responsive UI

• 📊 Interactive trading charts

• 🔒 Secure authentication flows

• 💼 Portfolio dashboard

🔧 Tech Stack

• Framework: Next.js 14 (App Router)

• Styling: Tailwind CSS + CSS Modules

• State Management: Zustand/Redux Toolkit

• API Client: Axios/React Query

• Forms: React Hook Form + Zod

• Testing: Jest + React Testing Library

🖠 Setup

git clone https://github.com/aditiids/trading-webapp.git
cd trading-webapp/frontend
npm install
cp .env.example .env.local
npm run dev

🌱 Environment Variables

NEXT_PUBLIC_API_URL=your_api_url
NEXT_PUBLIC_WS_URL=your_websocket_url

📂 Structure

frontend/
├── public/
├── src/
│   ├── app/
│   ├── components/
│   ├── lib/
│   ├── stores/
│   └── styles/
├── tailwind.config.js
└── next.config.js

📜 Scripts

npm run dev
npm run build
npm run start
npm test

🔗 Deploy

---

🔄 Big Data Pipeline -- Kafka + Spark

A real-time stock data processing pipeline using Apache Kafka, Apache Spark, and Alpha Vantage.

🔧 Your Role: Big Data Engineer

• Connect Kafka & Spark for data pipelines

• Ingest real-time stock data from Alpha Vantage

• Produce and consume Kafka messages

• Analyze and clean data using PySpark

• Store processed data or pass it downstream

🧱 Technologies

• Kafka + Zookeeper

• PySpark

• Cassandra

• Alpha Vantage API

• Kafka Python client

🧪 Setup & Installation

# Install Kafka, Spark, Java, Python
# Start Zookeeper & Kafka
kafka\bin\windows\zookeeper-server-start.bat config\zookeeper.properties
kafka\bin\windows\kafka-server-start.bat config\server.properties

🐍 Python Libraries

pip install kafka-python requests pyspark

🔁 Workflow

1. stock_producer.py

   • Calls Alpha Vantage API

   • Pushes data to Kafka topic stock_data

2. stock_consumer.py

   • Reads data from Kafka

   • Preprocesses with PySpark

   • Writes to new topic or Cassandra

python stock_producer.py
python stock_consumer.py

📄 Files

• stock_producer.py -- Producer script

• stock_consumer.py -- Spark consumer

🧠 AI/ML Integration (Future)

• Predict stock trends using Spark MLlib

• Portfolio optimization based on user profile

---

🗄️ Backend -- Cassandra + Java

A Java-based trading backend connected to a Cassandra database using DataStax Java Driver.

🔐 Features

• Buy/Sell stocks

• View transaction history

• Secure DB connection using Astra bundle

• Interactive CLI for easy interaction

📋 Requirements

• Java 21

• Apache Maven 3.8.8+

• Cassandra or Astra DB

• Secure Connect bundle

⚙️ Setup

git clone https://github.com/aditiids/trading-webapp.git
cd trading-webapp/CassandraJavaConnection

Configure credentials:

• Add secure bundle to your project

• Use the bundle path in Connector.java

📆 Project Structure

CassandraJavaConnection/
├── pom.xml
├── .idea/
├── src/
│   └── main/
│       └── java/
│           └── org/example/
│               ├── Connector.java
│               ├── Main.java
│               └── Operations.java

---

🌐 Trading Matchmaking Algorithm -- Java

A high-performance Order Matching Engine written in Java for trade execution.

✨ Features

• Matches buy and sell orders

• Uses limit price, FIFO rules

• Supports order history via Trade class

• Modular and extendable design

📚 Files

• OrderMatchingEngine.java -- Main class containing matching logic

• Order.class, Trade.class -- Helper classes

• Compiled .class files included

• A hello test file for demo/debug purposes

🔄 Future Enhancements

• Integration with Kafka + Cassandra

• RESTful API exposure

• More complex order types (Stop, Market, etc.)

---

📚 References & Resources

• Alpha Vantage API Docs

• Confluent Kafka Tutorials

• DataStax Java Driver for Cassandra

• Spark Kafka Streaming Docs

---

🤝 Contributing

1. Fork the repo

2. Create a new branch git checkout -b feature/your-feature

3. Commit changes git commit -m "Add feature"

4. Push branch git push origin feature/your-feature

5. Create a Pull Request

---

📄 License

MIT © Aditi Suryawanshi