Streaming reference

Kafka Streaming

Real time market data delivered over Kafka topics encoded as protobuf. Every topic retains 72 hours of messages.

retention72h encodingprotobuf topics20 messages36

Kafka or websocket

Both websocket and Kafka delivery are available. The websocket feed is the simpler integration connect and receive JSON and suits dashboards notifications and prototypes.

The Kafka feed is designed for production consumers. Offsets are tracked per consumer, so a disconnect or restart resumes exactly where it left off. A new consumer can seek back up to 72 hours to backfill state. Consumer groups distribute partitions across processes for horizontal scaling and every message is typed protobuf compact on the wire with backwards compatible schema evolution.

Email [email protected] if you would like more information. For custom enterprise pricing, redistribution licenses, or bespoke solutions, email [email protected]

Topics

all-option-trades Every option trade 1 msg · single type→ all-trade-report Every stock trade 1 msg · single type→ chain-frag Aggregated activity of single option contracts over 5 minute intervals 1 msg · single type→ flex-options All data related to FLEX options. Includes open interest, closing mark and FLEX option consolidations 2 msg · keyed by message key→ flow-alerts Options flow alerts: aggregates of option transactions that tripped a rule. See https://unusualwhales.com/option-flow-alerts/rules for rule definitions 1 msg · single type→ greek-flow Aggregated delta and vega flow of option trades per ticker and per expiry 2 msg · keyed by message key→ interpolated-iv Implied volatility and expected move interpolated onto fixed day horizons 1 msg · single type→ interval-flow Aggregated options activity of tickers over 5 minute intervals 1 msg · single type→ iv-term-structure ATM implied volatility and expected move per real option expiry 1 msg · single type→ live-gex Live gamma exposure keyed by different aggregation levels: ticker, strike, strike+expiry 3 msg · keyed by message key→ multi-leg-spreads Detected multi leg option spreads with their classified strategy 1 msg · single type→ net-flow Options net flow: market wide tide, per sector flow and near dated expiry tide 3 msg · keyed by message key→ option-states The live state of option chains. Contains open interest updates as well as volumes 1 msg · single type→ predictions-insiders Prediction market insider signals based on signal such as new account withs low activity, taking unusually large positions and more. 1 msg · single type→ predictions-positions Full states of prediction market outcome token positions for a given wallet/user whenever they change on chain 1 msg · single type→ predictions-trades Individual prediction market fills ingested from the Polymarket CTF exchange 1 msg · single type→ risk-reversal-skew Put vs call implied volatility skew at fixed deltas per expiry 1 msg · single type→ sec-filings SEC EDGAR filings: every filing as a general message plus enriched insider trade and 13F messages 3 msg · keyed by message key→ ticker-stock-states Per session OHLCV state of stocks 1 msg · single type→ trading-halts Trading halts, pauses and resumptions for stocks 1 msg · single type→