import json
from confluent_kafka import Producer

conf = {"bootstrap.servers": "localhost:9092"}
producer = Producer(conf)


def delivery_report(err, msg):
    if err is not None:
        print(f"Message delivery failed: {err}")
    else:
        print(f"Message delivered to {msg.topic()} [{msg.partition()}]")


def send_order_created_event(order_data: dict):
    data_str = json.dumps(order_data)

    producer.produce("orders", value=data_str.encode("utf-8"), callback=delivery_report)

    producer.flush()