This project demonstrates real-time streaming using Kafka. It simulates fake tweets and stock prices, performs sentiment analysis, and plots stock data live on a dashboard.
producer.py: Produces fake tweets and stock pricesconsumer_tweet_sentiment.py: Consumes tweets and analyzes sentimentdashboard_stock_plot.py: Plots live stock prices using Dash
- Install dependencies:
pip install -r requirements.txt
python -m textblob.download_corpora-
Start Kafka locally on
localhost:9092 -
Run each component in separate terminals:
python producer.py
python consumer_tweet_sentiment.py
python dashboard_stock_plot.py