From 4bc19be227f95ec06d33bca1b19bfa60afef99c6 Mon Sep 17 00:00:00 2001 From: alex Date: Thu, 16 Jul 2026 15:02:05 +0200 Subject: order is now sent to kafka --- order-service/app/kafka_producer.py | 20 ++++++++++++++++++++ 1 file changed, 20 insertions(+) create mode 100644 order-service/app/kafka_producer.py (limited to 'order-service/app/kafka_producer.py') diff --git a/order-service/app/kafka_producer.py b/order-service/app/kafka_producer.py new file mode 100644 index 0000000..6b24395 --- /dev/null +++ b/order-service/app/kafka_producer.py @@ -0,0 +1,20 @@ +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() -- cgit v1.2.3