Streaming admin for market data

Why this mattered

Market data streaming creates resources in several systems at once.

This belongs in the development timeline because Agentic Quant Platform is not a single feature. It is a local-first quant research and trading platform with FastAPI, Celery, Postgres, Iceberg, DuckDB, MLflow, Redis-backed RAG, strategy factories, agents, bots, streaming, and paper trading. The project only became useful once its infrastructure decisions were written down well enough to be repeated.

Design decision

The streaming admin surface keeps producers, topics, jobs, and dataset links connected instead of forcing the operator to infer state from names.

The practical stack around this decision includes Python, FastAPI, Celery, Redis, Postgres, SQLAlchemy, Alembic, Iceberg, DuckDB, MLflow, LiteLLM, CrewAI, LangGraph, vectorbt-pro, Kafka, Flink, Next.js. I try to keep the interfaces small: configuration describes intent, runtime code owns behavior, and operational notes explain what a future maintainer should check first.

What I would repeat

That is especially useful when the cluster and the quant platform are separate repositories.

The repeatable pattern is to make the boring path explicit. For this project that means clear repository boundaries, documented setup, predictable deployment commands, and enough observability to know whether the system is healthy or merely quiet.

Reader takeaway

If you are building something similar, start with the workflow you need to repeat every week. Then add only the platform pieces that make that workflow easier to recover, explain, and extend.