multi-leg-spreads

from confluent_kafka import Consumer
from unusualwhales.schema_pb2 import MultiLegSpread

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

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

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