> ## 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

# interval-flow

> Aggregated options activity of tickers over 5 minute intervals

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

## Messages on this topic

[all messages
TickerInterval
Aggregated options activity of a ticker over a 5 minute interval: call/put volumes split by trade side and trade type, net premium, greek flows and an IV snapshot at the interval open and close. All values are per interval, not running daily totals. This also applies to the cum\_net\_\*\_delta fields despite their name. The All and OtmOnly variants are published as separate messages. The message itself does not carry the ticker: the Kafka message key is the ticker of the underlying.
40 fields→](/docs/kafka/types/TickerInterval.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 TickerInterval

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

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

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