> ## Documentation Index
> Fetch the complete documentation index at: https://api.unusualwhales.com/docs/llms.txt
> Use this file to discover all available pages before exploring further.

> ## Agent Instructions
> API requests use the base URL https://api.unusualwhales.com and require a bearer token in the `Authorization` header (`Authorization: Bearer <API_KEY>`). Create and manage API tokens at https://unusualwhales.com/dashboard/api.
> For live market data inside an AI tool, use the Unusual Whales MCP server at https://unusualwhales.com/public-api/mcp.
> Instructions for agents using Unusual Whales tools: https://unusualwhales.com/skill.md

# flow-strike

> Option flow stats grouped by ticker and strike. Updates are published as INCREMENTAL updates for the time window they computed. If you store the data in a database you should be adding the values to the existing values in the database.

Topic
messages**1**
routing**single type**
encoding**protobuf**

## Messages on this topic

[all messages
FlowStrikeIntraday
An option activity update grouped by underlying ticker and strike. Updates are published as INCREMENTAL updates for the time window they computed. If you store the data in a database you should be adding the values to the existing values in the database.
24 fields→](/docs/kafka/types/FlowStrikeIntraday.md)

All messages on this topic are of a single type.

## Consume the topic

```python Python theme={null}
from confluent_kafka import Consumer
from unusualwhales.schema_pb2 import FlowStrikeIntraday

# CONFIG comes from the Connecting section of the Kafka overview.
consumer = Consumer(CONFIG | {"group.id": "my-flow-strike-consumer"})
consumer.subscribe(["flow-strike"])

while True:
    msg = consumer.poll(1.0)
    if msg is None or msg.error():
        continue

    event = FlowStrikeIntraday()
    event.ParseFromString(msg.value())
    print(event)
```