added my functionalities

[mohamedmuzamil008]

Summary by cubic

Adds a Kafka/Redpanda streaming pipeline and TimescaleDB storage for market data, plus a new backtesting engine aligned with live trading. Also enhances the WebSocket proxy and Flattrade adapter with scalable messaging and local testing tools.

• New Features

  • Kafka/Redpanda integration in WebSocket proxy and Flattrade adapter; sample producer/consumer scripts added.
  • TimescaleDB manager and ingestion service to store/query ticks from Kafka.
  • BacktestEngine and strategy runner using TimescaleDB data; added live trading README and supporting utilities.
  • Flattrade dummy WebSocket for local testing; optional local WS URL toggle.
  • Increased DB connection pool sizes for higher concurrency.
  • Added API key generation logs and reduced noisy Flattrade API response logs.

• Migration

  • Install deps: pip install -r requirements.txt (adds kafka-python, psycopg2, TA/plotting libs, etc.).
  • Ensure Kafka/Redpanda and TimescaleDB are running; set required env vars.
  • For local testing, run the Flattrade dummy WS and switch WS_URL if needed.
  • Verify Kafka topics (e.g., tick_data/tick_raw) match your broker setup.

[crypt0inf0]

Openalgo is a barebone implementation of all indian brokers but other features like backtesting, historic data, QuestDB and much more will be added on openengine.