This project demonstrates a real-time streaming pipeline for Solana swaps, designed as a multi-chain DEX aggregator architecture.

• Typescript microservice: Streams Solana swap transactions and publishes them to Kafka.
• Kafka: Handles real-time data streaming.
• Rust consumer: Reads swap events from Kafka and computes a price impact metric.

Solana (WebSocket/RPC)
   │
   ▼
[Typescript Streamer] ──▶ [Kafka Topic] ──▶ [Rust Price Impact Consumer]

1. Start Kafka & Zookeeper (see docker-compose.yml):

   docker-compose up -d

2. Run the Typescript streamer:

   cd ts-swap-streamer
   npm install && npm start

3. Run the Rust consumer:

   cd rust-price-impact
   cargo run

• Real-time Solana swap ingestion (can be extended to other chains).
• Kafka-based pipeline for scalable, reliable event streaming.
• Rust consumer for high-performance analytics (e.g., price impact, predictive insights).

Contact: Siraj Raval

Multi-chain DEX Aggregator & Trading Dashboard