predictions-positions

Topicmessages1routingsingle typeencodingprotobuf

Messages on this topic

all messagesPredictionsPositionSnapshot of a user’s position in a single outcome token, published to the predictions-positions Kafka topic every time the position changes on-chain. Each message carries the full new state of the position, not a delta. Prices and USD amounts are denominated in USDC; token amounts are in outcome tokens (shares), where one winning share redeems for $1.15 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 PredictionsPosition

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

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

    event = PredictionsPosition()
    event.ParseFromString(msg.value())
    print(event)

Overview

Topics

Messages

Enums

Messages on this topic

Consume the topic

​Messages on this topic

​Consume the topic

Messages on this topic

Consume the topic