flow-strike - Unusual Whales Docs

Topicmessages1routingsingle typeencodingprotobuf

Messages on this topic

all messagesFlowStrikeIntradayAn 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→

All messages on this topic are of a single type.

Consume the topic

Python

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)

Last modified on September 23, 2026